Home
last modified time | relevance | path

Searched refs:downStream (Results 1 – 20 of 20) sorted by relevance

/dports/devel/hadoop/hadoop-1.2.1/src/core/org/apache/hadoop/io/file/tfile/
H A DCompression.java114 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 DChunk.java53 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 DCompression.java114 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 DChunk.java53 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 DCompression.java166 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 DHadoopPipes.cc184 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 DHadoopPipes.cc184 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 Dteam.c527 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 DBED.py2049 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 DHTTP1xCodecTest.cpp845 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 DDataBlockEncodingTool.java429 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 DUBIQUOSS-10GEPON-PON-PROFILE-GROUP-MIB2101 downStream(1)
3163 downStream(1)
3907 downStream(1)
4029 downStream(1)
H A DUBIQUOSS-EPON-PON-PROFILE-GROUP-MIB1906 downStream(1)
2896 downStream(1)
/dports/biology/velvet/velvet_1.2.10/contrib/MetaVelvet-1.2.01/Velvet-1.1.06/
H A Dgraph.c1031 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 Dgraph.c1036 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 Dgraph.c1113 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 DSLE-EPON-MIB18057 downStream(2)
18193 downStream(2)
/dports/net-mgmt/observium/observium/mibs/dasan/
H A DSLE-EPON-MIB18057 downStream(2)
18193 downStream(2)
/dports/net-mgmt/netdisco-mibs/netdisco-mibs-4.010/rad/
H A Dipmux24.mib35376 downStream (2),
35383 downStream(2) - The OAM cell will be inserted in downStream.
/dports/net-mgmt/observium/observium/mibs/rad/
H A DRAD-MIB35376 downStream (2),
35383 downStream(2) - The OAM cell will be inserted in downStream.