Lines Matching refs:downStream
184 FILE* downStream; member in HadoopPipes::TextProtocol
193 while ((ch = getc(downStream)) != -1) { in readUpto()
206 downStream = down; in TextProtocol()
369 FileInStream* downStream; member in HadoopPipes::BinaryProtocol
463 downStream = new FileInStream(); in BinaryProtocol()
464 downStream->open(down); in BinaryProtocol()
477 cmd = deserializeInt(*downStream); in nextEvent()
489 deserializeString(digest, *downStream); in nextEvent()
490 deserializeString(challenge, *downStream); in nextEvent()
496 prot = deserializeInt(*downStream); in nextEvent()
502 entries = deserializeInt(*downStream); in nextEvent()
506 deserializeString(item, *downStream); in nextEvent()
515 deserializeString(keyType, *downStream); in nextEvent()
516 deserializeString(valueType, *downStream); in nextEvent()
524 deserializeString(split, *downStream); in nextEvent()
525 numReduces = deserializeInt(*downStream); in nextEvent()
526 piped = deserializeInt(*downStream); in nextEvent()
531 deserializeString(key, *downStream); in nextEvent()
532 deserializeString(value, *downStream); in nextEvent()
539 reduce = deserializeInt(*downStream); in nextEvent()
540 piped = deserializeInt(*downStream); in nextEvent()
545 deserializeString(key, *downStream); in nextEvent()
550 deserializeString(value, *downStream); in nextEvent()
566 delete downStream; in ~BinaryProtocol()