/dports/devel/hadoop/hadoop-1.2.1/src/core/org/apache/hadoop/io/file/tfile/ |
H A D | Compression.java | 114 InputStream downStream, Decompressor decompressor, in LZO() argument 125 bis1 = downStream; in LZO() 136 OutputStream downStream, Compressor compressor, in LZO() argument 147 bos1 = downStream; in LZO() 174 InputStream downStream, Decompressor decompressor, in GZ() argument 188 OutputStream downStream, Compressor compressor, in GZ() argument 194 bos1 = downStream; in GZ() 224 return downStream; in NONE() 229 OutputStream downStream, Compressor compressor, in NONE() argument 235 return downStream; in NONE() [all …]
|
H A D | Chunk.java | 53 public void reset(DataInputStream downStream) { in reset() argument 55 in = downStream; in reset()
|
/dports/devel/hadoop2/hadoop-2.7.2-src/hadoop-common-project/hadoop-common/src/main/java/org/apache/hadoop/io/file/tfile/ |
H A D | Compression.java | 114 InputStream downStream, Decompressor decompressor, in LZO() argument 125 bis1 = downStream; in LZO() 136 OutputStream downStream, Compressor compressor, in LZO() argument 147 bos1 = downStream; in LZO() 174 InputStream downStream, Decompressor decompressor, in GZ() argument 188 OutputStream downStream, Compressor compressor, in GZ() argument 194 bos1 = downStream; in GZ() 224 return downStream; in NONE() 229 OutputStream downStream, Compressor compressor, in NONE() argument 235 return downStream; in NONE() [all …]
|
H A D | Chunk.java | 53 public void reset(DataInputStream downStream) { in reset() argument 55 in = downStream; in reset()
|
/dports/databases/hbase/hbase-1.2.1/hbase-common/src/main/java/org/apache/hadoop/hbase/io/compress/ |
H A D | Compression.java | 166 InputStream downStream, Decompressor decompressor, in createDecompressionStream() argument 169 return new BufferedInputStream(downStream, downStreamBufferSize); in createDecompressionStream() 171 return downStream; in createDecompressionStream() 176 OutputStream downStream, Compressor compressor, in createCompressionStream() argument 179 return new BufferedOutputStream(downStream, downStreamBufferSize); in createCompressionStream() 182 return downStream; in createCompressionStream() 256 InputStream downStream, Decompressor decompressor, in createDecompressionStream() argument 265 codec.createInputStream(downStream, decompressor); in createDecompressionStream() 276 bos1 = new BufferedOutputStream(downStream, downStreamBufferSize); in createCompressionStream() 279 bos1 = downStream; in createCompressionStream() [all …]
|
/dports/devel/hadoop2/hadoop-2.7.2-src/hadoop-tools/hadoop-pipes/src/main/native/pipes/impl/ |
H A D | HadoopPipes.cc | 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() 496 prot = deserializeInt(*downStream); in nextEvent() 526 piped = deserializeInt(*downStream); in nextEvent() 531 deserializeString(key, *downStream); in nextEvent() [all …]
|
/dports/devel/hadoop/hadoop-1.2.1/src/c++/pipes/impl/ |
H A D | HadoopPipes.cc | 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() 496 prot = deserializeInt(*downStream); in nextEvent() 526 piped = deserializeInt(*downStream); in nextEvent() 531 deserializeString(key, *downStream); in nextEvent() [all …]
|
/dports/misc/team/team-3.1/ |
H A D | team.c | 527 Fd downStream; in mode() local 543 FdSet(&guy->downStream,downstream); in GuyOpen() 549 StreamSend(&guy->downStream,token,status,done) 674 return FdClose(&guy->upStream) && FdClose(&guy->downStream); in GuyClose()
|
/dports/biology/py-crossmap/CrossMap-0.5.4/lib/cmmodule/ |
H A D | BED.py | 2049 def findClosestTSS(self,outfile=None,downStream=50000,upStream=50000): argument 2147 def findClosestTTS(self,outfile=None,downStream=50000,upStream=50000): argument 2244 def findClosestPeak(self,mod, downStream=50000,upStream=50000): argument 2316 hits = ranges[chrom].find(TSS - upStream, TSS + downStream ) 2318 if strand == '+': hits = ranges[chrom].find(TSS - upStream, TES + downStream) 2319 if strand == '-': hits = ranges[chrom].find(TSS + upStream, TES - downStream) 2321 hits = ranges[chrom].find(TES - upStream, TES + downStream ) 2323 hits = ranges[chrom].find(CDSS - upStream, CDSS + downStream ) 2325 if strand == '+': hits = ranges[chrom].find(CDSS - upStream, CDSE + downStream) 2326 if strand == '-': hits = ranges[chrom].find(CDSS + upStream, CDSE - downStream) [all …]
|
/dports/www/proxygen/proxygen-2021.12.27.00/proxygen/lib/http/codec/test/ |
H A D | HTTP1xCodecTest.cpp | 845 auto downStream = downCodec.createStream(); in TEST() local 847 downCodec.generateHeader(blob, downStream, resp); in TEST() 849 blob, downStream, body->clone(), HTTPCodec::NoPadding, false); in TEST() 850 downCodec.generateTrailers(blob, downStream, trailers); in TEST() 851 downCodec.generateEOM(blob, downStream); in TEST()
|
/dports/databases/hbase/hbase-1.2.1/hbase-server/src/test/java/org/apache/hadoop/hbase/regionserver/ |
H A D | DataBlockEncodingTool.java | 429 ByteArrayInputStream downStream = new ByteArrayInputStream(compBuffer, in benchmarkAlgorithm() local 432 downStream, decompressor, 0); in benchmarkAlgorithm()
|
/dports/net-mgmt/librenms/librenms-21.5.1/mibs/ubiquoss/ |
H A D | UBIQUOSS-10GEPON-PON-PROFILE-GROUP-MIB | 2101 downStream(1) 3163 downStream(1) 3907 downStream(1) 4029 downStream(1)
|
H A D | UBIQUOSS-EPON-PON-PROFILE-GROUP-MIB | 1906 downStream(1) 2896 downStream(1)
|
/dports/biology/velvet/velvet_1.2.10/contrib/MetaVelvet-1.2.01/Velvet-1.1.06/ |
H A D | graph.c | 1031 boolean downStream) in appendSequenceToDescriptor() argument 1046 if (downStream) in appendSequenceToDescriptor() 1053 if (!downStream) in appendSequenceToDescriptor()
|
/dports/biology/velvet/velvet_1.2.10/src/ |
H A D | graph.c | 1036 boolean downStream) in appendSequenceToDescriptor() argument 1051 if (downStream) in appendSequenceToDescriptor() 1058 if (!downStream) in appendSequenceToDescriptor()
|
/dports/biology/velvet/velvet_1.2.10/contrib/MetaVelvet-v0.3.1/src/ |
H A D | graph.c | 1113 boolean downStream) in appendSequenceToDescriptor() argument 1128 if (downStream) in appendSequenceToDescriptor() 1135 if (!downStream) in appendSequenceToDescriptor()
|
/dports/net-mgmt/librenms/librenms-21.5.1/mibs/dasan/ |
H A D | SLE-EPON-MIB | 18057 downStream(2) 18193 downStream(2)
|
/dports/net-mgmt/observium/observium/mibs/dasan/ |
H A D | SLE-EPON-MIB | 18057 downStream(2) 18193 downStream(2)
|
/dports/net-mgmt/netdisco-mibs/netdisco-mibs-4.010/rad/ |
H A D | ipmux24.mib | 35376 downStream (2), 35383 downStream(2) - The OAM cell will be inserted in downStream.
|
/dports/net-mgmt/observium/observium/mibs/rad/ |
H A D | RAD-MIB | 35376 downStream (2), 35383 downStream(2) - The OAM cell will be inserted in downStream.
|