cascading.tuple.TupleEntry.isUnmodifiable()方法的使用及代码示例

x33g5p2x  于2022-01-29 转载在 其他  
字(6.6k)|赞(0)|评价(0)|浏览(82)

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

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" );
 }
}

相关文章