本文整理了Java中cascading.flow.Flow.getSink()方法的一些代码示例，展示了Flow.getSink()的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台，是从一些精选项目中提取出来的代码，具有较强的参考意义，能在一定程度帮忙到你。Flow.getSink()方法的具体详情如下：
包路径：cascading.flow.Flow
类名称：Flow
方法名：getSink

Flow.getSink介绍

[英]Method getSink returns the first sink of this Flow object.
[中]方法getSink返回此流对象的第一个接收器。

代码示例

代码示例来源：origin: cwensel/cascading

default Stream<Tuple> getSinkTupleStreamCopy( String name, Fields selector )
 {
 return TupleStream.tupleStream( getSink( name ), getFlowProcess(), selector );
 }
}

代码示例来源：origin: cwensel/cascading

default Stream<TupleEntry> getSinkEntryStreamCopy( String name, Fields selector )
 {
 return TupleEntryStream.entryStreamCopy( getSink( name ), getFlowProcess(), selector );
 }

代码示例来源：origin: cwensel/cascading

default Stream<Tuple> getSinkTupleStream( String name, Fields selector )
 {
 return TupleStream.tupleStream( getSink( name ), getFlowProcess(), selector );
 }

代码示例来源：origin: cwensel/cascading

default Stream<TupleEntry> getSinkEntryStreamCopy()
 {
 return TupleEntryStream.entryStreamCopy( getSink(), getFlowProcess() );
 }

代码示例来源：origin: cwensel/cascading

default Stream<TupleEntry> getSinkEntryStream( String name, Fields selector )
 {
 return TupleEntryStream.entryStream( getSink( name ), getFlowProcess(), selector );
 }

代码示例来源：origin: cwensel/cascading

default Stream<TupleEntry> getSinkEntryStreamCopy( Fields selector )
 {
 return TupleEntryStream.entryStreamCopy( getSink(), getFlowProcess(), selector );
 }

代码示例来源：origin: cwensel/cascading

default Stream<Tuple> getSinkTupleStreamCopy()
 {
 return TupleStream.tupleStream( getSink(), getFlowProcess() );
 }

代码示例来源：origin: cwensel/cascading

default Stream<Tuple> getSinkTupleStreamCopy( String name )
 {
 return TupleStream.tupleStream( getSink( name ), getFlowProcess() );
 }

代码示例来源：origin: cwensel/cascading

default Stream<Tuple> getSinkTupleStreamCopy( Fields selector )
 {
 return TupleStream.tupleStream( getSink(), getFlowProcess(), selector );
 }

代码示例来源：origin: cwensel/cascading

default Stream<Tuple> getSinkTupleStream( String name )
 {
 return TupleStream.tupleStream( getSink( name ), getFlowProcess() );
 }

代码示例来源：origin: cwensel/cascading

default Stream<TupleEntry> getSinkEntryStream()
 {
 return TupleEntryStream.entryStream( getSink(), getFlowProcess() );
 }

代码示例来源：origin: cwensel/cascading

default Stream<TupleEntry> getSinkEntryStream( Fields selector )
 {
 return TupleEntryStream.entryStream( getSink(), getFlowProcess(), selector );
 }

代码示例来源：origin: cwensel/cascading

default Stream<Tuple> getSinkTupleStream()
 {
 return TupleStream.tupleStream( getSink(), getFlowProcess() );
 }

代码示例来源：origin: cwensel/cascading

default Stream<Tuple> getSinkTupleStream( Fields selector )
 {
 return TupleStream.tupleStream( getSink(), getFlowProcess(), selector );
 }

代码示例来源：origin: cwensel/cascading

default Stream<TupleEntry> getSinkEntryStream( String name )
 {
 return TupleEntryStream.entryStream( getSink( name ), getFlowProcess() );
 }

代码示例来源：origin: cwensel/cascading

default Stream<TupleEntry> getSinkEntryStreamCopy( String name )
 {
 return TupleEntryStream.entryStreamCopy( getSink( name ), getFlowProcess() );
 }

代码示例来源：origin: cascading/lingual-core

@Override
public void onCompleted( Flow flow )
 {
 if( !flow.getStats().isSuccessful() )
  return;
 platformBroker.addResultToSchema( flow.getSink(), lingualConnection.get() );
 }

代码示例来源：origin: cwensel/cascading

public static List<Tuple> getSinkAsList( Flow flow ) throws IOException
 {
 return asCollection( flow, flow.getSink(), Fields.ALL, new ArrayList<Tuple>() );
 }

代码示例来源：origin: cascading/cascading-platform

@Test
public void testMultiTapCascade() throws IOException
 {
 getPlatform().copyFromLocal( inputFileIps );
 String path = "multitap";
 Flow first = previousMultiTapFlow( path, "first" );
 Flow second = previousMultiTapFlow( path, "second" );
 Flow multitap = multiTapFlow( Tap.taps( first.getSink(), second.getSink() ), path );
 Cascade cascade = new CascadeConnector( getProperties() ).connect( multitap, first, second );
 cascade.start();
 cascade.complete();
 validateLength( multitap, 40 );
 }

代码示例来源：origin: cwensel/cascading

@Test
public void testMultiTapCascade() throws IOException
 {
 getPlatform().copyFromLocal( inputFileIps );
 String path = "multitap";
 Flow first = previousMultiTapFlow( path, "first" );
 Flow second = previousMultiTapFlow( path, "second" );
 Flow multitap = multiTapFlow( Tap.taps( first.getSink(), second.getSink() ), path );
 Cascade cascade = new CascadeConnector( getProperties() ).connect( multitap, first, second );
 cascade.start();
 cascade.complete();
 validateLength( multitap, 40 );
 }