本文整理了Java中cascading.tuple.TupleEntry.isUnmodifiable()
方法的一些代码示例,展示了TupleEntry.isUnmodifiable()
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。TupleEntry.isUnmodifiable()
方法的具体详情如下:
包路径:cascading.tuple.TupleEntry
类名称:TupleEntry
方法名:isUnmodifiable
[英]Field isUnmodifiable
[中]字段是不可修改的
代码示例来源:origin: cwensel/cascading
public void aggregate( FlowProcess flowProcess, AggregatorCall aggregatorCall )
{
if( !aggregatorCall.getGroup().isUnmodifiable() )
throw new IllegalStateException( "is modifiable" );
if( !aggregatorCall.getGroup().getTuple().isUnmodifiable() )
throw new IllegalStateException( "is modifiable" );
if( !aggregatorCall.getArguments().isUnmodifiable() )
throw new IllegalStateException( "is modifiable" );
if( !aggregatorCall.getArguments().getTuple().isUnmodifiable() )
throw new IllegalStateException( "is modifiable" );
}
代码示例来源:origin: cwensel/cascading
public void start( FlowProcess flowProcess, AggregatorCall aggregatorCall )
{
if( !aggregatorCall.getGroup().isUnmodifiable() )
throw new IllegalStateException( "is modifiable" );
if( !aggregatorCall.getGroup().getTuple().isUnmodifiable() )
throw new IllegalStateException( "is modifiable" );
}
代码示例来源:origin: cwensel/cascading
public boolean isRemove( FlowProcess flowProcess, FilterCall filterCall )
{
if( !filterCall.getArguments().isUnmodifiable() )
throw new IllegalStateException( "is modifiable" );
if( !filterCall.getArguments().getTuple().isUnmodifiable() )
throw new IllegalStateException( "is modifiable" );
return false;
}
}
代码示例来源:origin: cascading/cascading-platform
public boolean isRemove( FlowProcess flowProcess, FilterCall filterCall )
{
if( !filterCall.getArguments().isUnmodifiable() )
throw new IllegalStateException( "is modifiable" );
if( !filterCall.getArguments().getTuple().isUnmodifiable() )
throw new IllegalStateException( "is modifiable" );
return false;
}
}
代码示例来源:origin: cascading/cascading-platform
public void start( FlowProcess flowProcess, AggregatorCall aggregatorCall )
{
if( !aggregatorCall.getGroup().isUnmodifiable() )
throw new IllegalStateException( "is modifiable" );
if( !aggregatorCall.getGroup().getTuple().isUnmodifiable() )
throw new IllegalStateException( "is modifiable" );
}
代码示例来源:origin: cascading/cascading-platform
public void aggregate( FlowProcess flowProcess, AggregatorCall aggregatorCall )
{
if( !aggregatorCall.getGroup().isUnmodifiable() )
throw new IllegalStateException( "is modifiable" );
if( !aggregatorCall.getGroup().getTuple().isUnmodifiable() )
throw new IllegalStateException( "is modifiable" );
if( !aggregatorCall.getArguments().isUnmodifiable() )
throw new IllegalStateException( "is modifiable" );
if( !aggregatorCall.getArguments().getTuple().isUnmodifiable() )
throw new IllegalStateException( "is modifiable" );
}
代码示例来源:origin: cascading/cascading-platform
public void complete( FlowProcess flowProcess, AggregatorCall aggregatorCall )
{
if( !aggregatorCall.getGroup().isUnmodifiable() )
throw new IllegalStateException( "is modifiable" );
if( !aggregatorCall.getGroup().getTuple().isUnmodifiable() )
throw new IllegalStateException( "is modifiable" );
Tuple result = new Tuple( "some value" );
aggregatorCall.getOutputCollector().add( result );
if( result.isUnmodifiable() )
throw new IllegalStateException( "is unmodifiable" );
}
}
代码示例来源:origin: cwensel/cascading
public void complete( FlowProcess flowProcess, AggregatorCall aggregatorCall )
{
if( !aggregatorCall.getGroup().isUnmodifiable() )
throw new IllegalStateException( "is modifiable" );
if( !aggregatorCall.getGroup().getTuple().isUnmodifiable() )
throw new IllegalStateException( "is modifiable" );
Tuple result = new Tuple( "some value" );
aggregatorCall.getOutputCollector().add( result );
if( result.isUnmodifiable() )
throw new IllegalStateException( "is unmodifiable" );
}
}
代码示例来源:origin: cwensel/cascading
public void operate( FlowProcess flowProcess, BufferCall bufferCall )
{
if( !bufferCall.getGroup().isUnmodifiable() )
throw new IllegalStateException( "is modifiable" );
if( !bufferCall.getGroup().getTuple().isUnmodifiable() )
throw new IllegalStateException( "is modifiable" );
if( bufferCall.getJoinerClosure() != null )
throw new IllegalStateException( "joiner closure should be null" );
Iterator<TupleEntry> iterator = bufferCall.getArgumentsIterator();
while( iterator.hasNext() )
{
TupleEntry tupleEntry = iterator.next();
if( !tupleEntry.isUnmodifiable() )
throw new IllegalStateException( "is modifiable" );
if( !tupleEntry.getTuple().isUnmodifiable() )
throw new IllegalStateException( "is modifiable" );
Tuple result = new Tuple( tupleEntry.getTuple() );
bufferCall.getOutputCollector().add( result );
if( result.isUnmodifiable() )
throw new IllegalStateException( "is unmodifiable" );
}
}
}
代码示例来源:origin: cascading/cascading-platform
public void operate( FlowProcess flowProcess, BufferCall bufferCall )
{
if( !bufferCall.getGroup().isUnmodifiable() )
throw new IllegalStateException( "is modifiable" );
if( !bufferCall.getGroup().getTuple().isUnmodifiable() )
throw new IllegalStateException( "is modifiable" );
if( bufferCall.getJoinerClosure() != null )
throw new IllegalStateException( "joiner closure should be null" );
Iterator<TupleEntry> iterator = bufferCall.getArgumentsIterator();
while( iterator.hasNext() )
{
TupleEntry tupleEntry = iterator.next();
if( !tupleEntry.isUnmodifiable() )
throw new IllegalStateException( "is modifiable" );
if( !tupleEntry.getTuple().isUnmodifiable() )
throw new IllegalStateException( "is modifiable" );
Tuple result = new Tuple( tupleEntry.getTuple() );
bufferCall.getOutputCollector().add( result );
if( result.isUnmodifiable() )
throw new IllegalStateException( "is unmodifiable" );
}
}
}
代码示例来源:origin: cwensel/cascading
public void operate( FlowProcess flowProcess, FunctionCall functionCall )
{
if( !functionCall.getArguments().isUnmodifiable() )
throw new IllegalStateException( "is modifiable" );
if( !functionCall.getArguments().getTuple().isUnmodifiable() )
throw new IllegalStateException( "is modifiable" );
Tuple result = new Tuple( functionCall.getArguments().getTuple() );
functionCall.getOutputCollector().add( result );
if( result.isUnmodifiable() )
throw new IllegalStateException( "is unmodifiable" );
}
}
代码示例来源:origin: cascading/cascading-platform
public void operate( FlowProcess flowProcess, FunctionCall functionCall )
{
if( !functionCall.getArguments().isUnmodifiable() )
throw new IllegalStateException( "is modifiable" );
if( !functionCall.getArguments().getTuple().isUnmodifiable() )
throw new IllegalStateException( "is modifiable" );
Tuple result = new Tuple( functionCall.getArguments().getTuple() );
functionCall.getOutputCollector().add( result );
if( result.isUnmodifiable() )
throw new IllegalStateException( "is unmodifiable" );
}
}
内容来源于网络,如有侵权,请联系作者删除!