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

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

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

TupleEntry.setObject介绍

[英]Method set sets the value in the given field or position.
[中]

代码示例

代码示例来源：origin: elastic/elasticsearch-hadoop

static void setObject(TupleEntry entry, Comparable<?> field, Object object) {
  entry.setObject(field, object);
}

代码示例来源：origin: elastic/elasticsearch-hadoop

static void setObject(TupleEntry entry, Comparable<?> field, Object object) {
  if (object != null && entry.getFields().getType(field) instanceof CoercibleType) {
    entry.setObject(field, object.toString());
  }
  else {
    entry.setObject(field, object);
  }
}

代码示例来源：origin: elastic/elasticsearch-hadoop

entry.setObject(field, result);

代码示例来源：origin: org.elasticsearch/elasticsearch-hadoop

static void setObject(TupleEntry entry, Comparable<?> field, Object object) {
  entry.setObject(field, object);
}

代码示例来源：origin: org.elasticsearch/elasticsearch-hadoop

static void setObject(TupleEntry entry, Comparable<?> field, Object object) {
  if (object != null && entry.getFields().getType(field) instanceof CoercibleType) {
    entry.setObject(field, object.toString());
  }
  else {
    entry.setObject(field, object);
  }
}

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

@Override
public boolean source( FlowProcess<? extends Properties> flowProcess, SourceCall<LineNumberReader, InputStream> sourceCall ) throws IOException
 {
 String line = sourceCall.getContext().readLine();
 if( line == null )
  return false;
 TupleEntry incomingEntry = sourceCall.getIncomingEntry();
 JsonNode jsonNode = null;
 if( !line.isEmpty() )
  jsonNode = mapper.readTree( line );
 incomingEntry.setObject( 0, jsonNode );
 return true;
 }

代码示例来源：origin: LiveRamp/cascading_ext

public TupleEntry allocateTuple(Fields subSetOfFields, Object... values) {
 if (resuableEntry == null) {
  resuableEntry = new TupleEntry(allFields, Tuple.size(allFields.size()));
 }
 for (Comparable field : resuableEntry.getFields()) {
  resuableEntry.setObject(field, null);
 }
 for (int i = 0; i < subSetOfFields.size(); i++) {
  resuableEntry.setObject(subSetOfFields.get(i), values[i]);
 }
 return resuableEntry;
}

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

@Test
public void testRegexFilter() throws Exception
 {
 TupleEntry entry = new TupleEntry( new Fields( "json", JSONCoercibleType.TYPE ), Tuple.size( 1 ) );
 entry.setObject( 0, JSONData.nested );
 assertTrue( invokeFilter( new JSONRegexFilter( "/person/name", Pattern.compile( "John D Doe" ) ), entry ) );
 assertTrue( invokeFilter( new JSONRegexFilter( "/person/name", Pattern.compile( "^John$" ) ), entry ) );
 assertFalse( invokeFilter( new JSONRegexFilter( "/person/name", Pattern.compile( "^John Doe$" ) ), entry ) );
 assertFalse( invokeFilter( new JSONRegexFilter( "/person/name", Pattern.compile( "John Doe" ) ), entry ) );
 assertFalse( invokeFilter( new JSONRegexFilter( "/person/name", Pattern.compile( "John[ ]Doe$" ) ), entry ) );
 }
}

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

@Test
public void testRegexFilter() throws Exception
 {
 TupleEntry entry = new TupleEntry( new Fields( "json", JSONCoercibleType.TYPE ), Tuple.size( 1 ) );
 entry.setObject( 0, JSONData.nested );
 assertTrue( invokeFilter( new JSONRegexFilter( "/person/name", Pattern.compile( "John D Doe" ) ), entry ) );
 assertTrue( invokeFilter( new JSONRegexFilter( "/person/name", Pattern.compile( "^John$" ) ), entry ) );
 assertFalse( invokeFilter( new JSONRegexFilter( "/person/name", Pattern.compile( "^John Doe$" ) ), entry ) );
 assertFalse( invokeFilter( new JSONRegexFilter( "/person/name", Pattern.compile( "John Doe" ) ), entry ) );
 assertFalse( invokeFilter( new JSONRegexFilter( "/person/name", Pattern.compile( "John[ ]Doe$" ) ), entry ) );
 }
}

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

@Test
public void testCreateMap() throws Exception
 {
 TupleEntry entry = new TupleEntry(
  new Fields( "name", String.class ),
  Tuple.size( 1 )
 );
 entry.setObject( 0, "Jane Doe" );
 JSONCreateFunction function = new JSONCreateFunction( new Fields( "result" ), singletonMap( new Fields( "name", String.class ), "/person/name" ) );
 TupleListCollector result = invokeFunction( function, entry, new Fields( "result" ) );
 JsonNode value = (JsonNode) result.iterator().next().getObject( 0 );
 assertNotNull( value );
 assertEquals( "Jane Doe", value.at( "/person/name" ).textValue() );
 }

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

@Test
public void testCreateMapResolved() throws Exception
 {
 TupleEntry entry = new TupleEntry(
  new Fields( "name", String.class ),
  Tuple.size( 1 )
 );
 entry.setObject( 0, "Jane Doe" );
 JSONCreateFunction function = new JSONCreateFunction( new Fields( "result" ), singletonMap( new Fields( 0, String.class ), "/person/name" ) );
 TupleListCollector result = invokeFunction( function, entry, new Fields( "result" ) );
 JsonNode value = (JsonNode) result.iterator().next().getObject( 0 );
 assertNotNull( value );
 assertEquals( "Jane Doe", value.at( "/person/name" ).textValue() );
 }

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

@Test
public void testGetMap() throws Exception
 {
 TupleEntry entry = new TupleEntry( new Fields( "json", JSONCoercibleType.TYPE ), Tuple.size( 1 ) );
 entry.setObject( 0, JSONData.nested );
 // the map ctor really expects large numbers of entries to be useful
 JSONGetFunction function = new JSONGetFunction( singletonMap( new Fields( "result" ), "/person/name" ) );
 TupleListCollector result = invokeFunction( function, entry, new Fields( "result" ) );
 Object value = result.iterator().next().getObject( 0 );
 assertNotNull( value );
 assertEquals( "John Doe", ( (TextNode) value ).textValue() );
 }
}

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

@Test
public void testGetMap() throws Exception
 {
 TupleEntry entry = new TupleEntry( new Fields( "json", JSONCoercibleType.TYPE ), Tuple.size( 1 ) );
 entry.setObject( 0, JSONData.nested );
 // the map ctor really expects large numbers of entries to be useful
 JSONGetFunction function = new JSONGetFunction( singletonMap( new Fields( "result" ), "/person/name" ) );
 TupleListCollector result = invokeFunction( function, entry, new Fields( "result" ) );
 Object value = result.iterator().next().getObject( 0 );
 assertNotNull( value );
 assertEquals( "John Doe", ( (TextNode) value ).textValue() );
 }
}

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

@Test
public void testGetMissing() throws Exception
 {
 TupleEntry entry = new TupleEntry( new Fields( "json", JSONCoercibleType.TYPE ), Tuple.size( 1 ) );
 entry.setObject( 0, JSONData.nested );
 JSONGetFunction function = new JSONGetFunction( new Fields( "result" ), "/person/foobar" );
 TupleListCollector result = invokeFunction( function, entry, new Fields( "result" ) );
 Object value = result.iterator().next().getObject( 0 );
 assertNull( value );
 }

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

@Test
public void testGetMissing() throws Exception
 {
 TupleEntry entry = new TupleEntry( new Fields( "json", JSONCoercibleType.TYPE ), Tuple.size( 1 ) );
 entry.setObject( 0, JSONData.nested );
 JSONGetFunction function = new JSONGetFunction( new Fields( "result" ), "/person/foobar" );
 TupleListCollector result = invokeFunction( function, entry, new Fields( "result" ) );
 Object value = result.iterator().next().getObject( 0 );
 assertNull( value );
 }

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

@Test
public void testCreateDeep() throws Exception
 {
 TupleEntry entry = new TupleEntry(
  new Fields( "name", String.class ),
  Tuple.size( 1 )
 );
 entry.setObject( 0, "Jane Doe" );
 JSONCreateFunction function = new JSONCreateFunction( new Fields( "result" ), new Fields( "name", String.class ), "/person/foo/name" );
 TupleListCollector result = invokeFunction( function, entry, new Fields( "result" ) );
 JsonNode value = (JsonNode) result.iterator().next().getObject( 0 );
 assertNotNull( value );
 assertEquals( "Jane Doe", value.at( "/person/foo/name" ).textValue() );
 }

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

@Test(expected = OperationException.class)
public void testGetMissingFail() throws Exception
 {
 TupleEntry entry = new TupleEntry( new Fields( "json", JSONCoercibleType.TYPE ), Tuple.size( 1 ) );
 entry.setObject( 0, JSONData.nested );
 JSONGetFunction function = new JSONGetFunction( new Fields( "result" ), true, "/person/foobar" );
 invokeFunction( function, entry, new Fields( "result" ) );
 }

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

@Test
public void testGet() throws Exception
 {
 TupleEntry entry = new TupleEntry( new Fields( "json", JSONCoercibleType.TYPE ), Tuple.size( 1 ) );
 entry.setObject( 0, JSONData.nested );
 JSONGetFunction function = new JSONGetFunction( new Fields( "result" ), "/person/name" );
 TupleListCollector result = invokeFunction( function, entry, new Fields( "result" ) );
 Object value = result.iterator().next().getObject( 0 );
 assertNotNull( value );
 assertEquals( "John Doe", ( (TextNode) value ).textValue() );
 }

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

@Test
public void testGet() throws Exception
 {
 TupleEntry entry = new TupleEntry( new Fields( "json", JSONCoercibleType.TYPE ), Tuple.size( 1 ) );
 entry.setObject( 0, JSONData.nested );
 JSONGetFunction function = new JSONGetFunction( new Fields( "result" ), "/person/name" );
 TupleListCollector result = invokeFunction( function, entry, new Fields( "result" ) );
 Object value = result.iterator().next().getObject( 0 );
 assertNotNull( value );
 assertEquals( "John Doe", ( (TextNode) value ).textValue() );
 }

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

@Test(expected = OperationException.class)
public void testGetMissingFail() throws Exception
 {
 TupleEntry entry = new TupleEntry( new Fields( "json", JSONCoercibleType.TYPE ), Tuple.size( 1 ) );
 entry.setObject( 0, JSONData.nested );
 JSONGetFunction function = new JSONGetFunction( new Fields( "result" ), true, "/person/foobar" );
 invokeFunction( function, entry, new Fields( "result" ) );
 }

内容来源于网络，如有侵权，请联系作者删除！

TupleEntry

相关文章

    查看更多
    微信公众号

    热门标签

    更多
    JavaquerypythonNode开发语言requestUtil数据库Table后端算法LoggerMessageElementParser

    最新文章

    更多
    • 蜀ICP备13028337号-1 大数据知识库 https://www.saoniuhuo.com © All rights reserved
    • 本站内容来源互联网,如果侵犯您的权益请联系我们删除, 联系方式：448109455@qq.com