Home
last modified time | relevance | path

Searched defs:createRecordWriter (Results 1 – 18 of 18) sorted by relevance

/dports/java/servingxml/servingxml-1.1.2/servingxml-framework/src/main/java/com/servingxml/components/recordio/
H A DRecordWriterFactory.java34 RecordWriter createRecordWriter(ServiceContext context, Flow flow); in createRecordWriter() method
H A DRecordWriterFactoryPrefilter.java44 public RecordWriter createRecordWriter(ServiceContext context, Flow flow) { in createRecordWriter() method in RecordWriterFactoryPrefilter
H A DAbstractRecordWriterFactory.java43 public abstract RecordWriter createRecordWriter(ServiceContext context, Flow flow); in createRecordWriter() method in AbstractRecordWriterFactory
H A DBatchedRecordWriterFactoryAssembler.java98 public RecordWriter createRecordWriter(ServiceContext context, Flow flow) { in createRecordWriter() method in BatchedRecordWriterFactory
/dports/java/servingxml/servingxml-1.1.2/servingxml-framework/src/main/java/com/servingxml/components/sql/
H A DSqlWriterFactory.java49 public RecordWriter createRecordWriter(ServiceContext context, Flow flow) { in createRecordWriter() method in SqlWriterFactory
/dports/java/servingxml/servingxml-1.1.2/servingxml-framework/src/main/java/com/servingxml/components/flatfile/layout/
H A DFlatFileWriterFactory.java54 public RecordWriter createRecordWriter(ServiceContext context, Flow flow) { in createRecordWriter() method in FlatFileWriterFactory
H A DDefaultFlatFileWriterFactory.java53 public RecordWriter createRecordWriter(ServiceContext context, Flow flow) { in createRecordWriter() method in DefaultFlatFileWriterFactory
H A DFlatFile.java74 …public RecordWriter createRecordWriter(ServiceContext context, Flow flow, StreamSinkFactory sinkFa… in createRecordWriter() method in FlatFile
/dports/devel/hadoop/hadoop-1.2.1/c++/Linux-i386-32/include/hadoop/
H A DTemplateFactory.hh82 RecordWriter* createRecordWriter(ReduceContext& context) const { in createRecordWriter() function in HadoopPipes::TemplateFactory
H A DPipes.hh243 virtual RecordWriter* createRecordWriter(ReduceContext& context) const { in createRecordWriter() function in HadoopPipes::Factory
/dports/devel/hadoop/hadoop-1.2.1/c++/Linux-amd64-64/include/hadoop/
H A DTemplateFactory.hh82 RecordWriter* createRecordWriter(ReduceContext& context) const { in createRecordWriter() function in HadoopPipes::TemplateFactory
H A DPipes.hh243 virtual RecordWriter* createRecordWriter(ReduceContext& context) const { in createRecordWriter() function in HadoopPipes::Factory
/dports/devel/hadoop2/hadoop-2.7.2-src/hadoop-tools/hadoop-pipes/src/main/native/pipes/api/hadoop/
H A DTemplateFactory.hh82 RecordWriter* createRecordWriter(ReduceContext& context) const { in createRecordWriter() function in HadoopPipes::TemplateFactory
H A DPipes.hh243 virtual RecordWriter* createRecordWriter(ReduceContext& context) const { in createRecordWriter() function in HadoopPipes::Factory
/dports/devel/hadoop/hadoop-1.2.1/src/c++/pipes/api/hadoop/
H A DTemplateFactory.hh82 RecordWriter* createRecordWriter(ReduceContext& context) const { in createRecordWriter() function in HadoopPipes::TemplateFactory
H A DPipes.hh243 virtual RecordWriter* createRecordWriter(ReduceContext& context) const { in createRecordWriter() function in HadoopPipes::Factory
/dports/devel/hadoop2/hadoop-2.7.2-src/hadoop-mapreduce-project/hadoop-mapreduce-client/hadoop-mapreduce-client-core/src/main/java/org/apache/hadoop/mapred/lib/
H A DLazyOutputFormat.java115 private void createRecordWriter() throws IOException { in createRecordWriter() method in LazyOutputFormat.LazyRecordWriter
/dports/databases/hbase/hbase-1.2.1/hbase-server/src/main/java/org/apache/hadoop/hbase/mapreduce/
H A DHFileOutputFormat2.java118 createRecordWriter(final TaskAttemptContext context) in createRecordWriter() method in HFileOutputFormat2