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

Tuple.getFields介绍

[英]Gets the names of the fields in this tuple.
[中]获取此元组中字段的名称。

代码示例

代码示例来源：origin: apache/storm

@Override
  public byte[] format(Tuple tuple) {
    StringBuilder sb = new StringBuilder();
    Fields fields = this.fields == null ? tuple.getFields() : this.fields;
    int size = fields.size();
    for (int i = 0; i < size; i++) {
      sb.append(tuple.getValueByField(fields.get(i)));
      if (i != size - 1) {
        sb.append(this.fieldDelimiter);
      }
    }
    sb.append(this.recordDelimiter);
    return sb.toString().getBytes();
  }
}

代码示例来源：origin: apache/storm

@Test
public void testTestTuple() throws Exception {
  Tuple tuple = Testing.testTuple(new Values("james", "bond"));
  assertThat(tuple.getValues(), is(new Values("james", "bond")));
  assertThat(tuple.getSourceStreamId(), is(Utils.DEFAULT_STREAM_ID));
  assertThat(tuple.getFields().toList(), is(Arrays.asList("field1", "field2")));
  assertThat(tuple.getSourceComponent(), is("component"));
}

代码示例来源：origin: apache/storm

@Test
public void testTestTupleWithMkTupleParam() throws Exception {
  MkTupleParam mkTupleParam = new MkTupleParam();
  mkTupleParam.setStream("test-stream");
  mkTupleParam.setComponent("test-component");
  mkTupleParam.setFields("fname", "lname");
  Tuple tuple = Testing.testTuple(new Values("james", "bond"), mkTupleParam);
  assertThat(tuple.getValues(), is(new Values("james", "bond")));
  assertThat(tuple.getSourceStreamId(), is("test-stream"));
  assertThat(tuple.getFields().toList(), is(Arrays.asList("fname", "lname")));
  assertThat(tuple.getSourceComponent(), is("test-component"));
}

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

protected Result doWrite(Tuple tuple, Generator generator, String parentField) {
    Fields fields = tuple.getFields();

    generator.writeBeginObject();
    for (String field : fields) {
      if (shouldKeep(parentField, field)) {
        generator.writeFieldName(field);
        Object value = tuple.getValueByField(field);

        if (value instanceof Tuple) {
          Result result = write((Tuple) value, generator);
          if (!result.isSuccesful()) {
            return result;
          }
        }

        else {
          Result result = jdkWriter.write(value, generator);
          if (!result.isSuccesful()) {
            return result;
          }
        }
      }
    }
    generator.writeEndObject();
    return Result.SUCCESFUL();
  }
}

代码示例来源：origin: apache/metron

throw new IOException("Unable to retrieve " + tupleRowKeyField + " from " + tuple + " [ " + Joiner.on(',').join(tuple.getFields()) + " ]", iae);

代码示例来源：origin: apache/metron

return metadata;
Fields tupleFields = t.getFields();
if(tupleFields == null) {
 return metadata;

代码示例来源：origin: apache/metron

private static Tuple createTuple(Map<String, Object> kafkaFields, String metadata) throws Exception {
 List<Map.Entry<String, Object>> fields = new ArrayList<>();
 for(Map.Entry<String, Object> kv : kafkaFields.entrySet()) {
  fields.add(kv);
 }
 Tuple t = mock(Tuple.class);
 Fields f = mock(Fields.class);
 when(f.size()).thenReturn(fields.size()+2);
 for(int i = 0;i < fields.size();++i) {
  when(f.get(eq(i + 2))).thenReturn(fields.get(i).getKey());
  when(t.getValue(eq(i + 2))).thenReturn(fields.get(i).getValue());
 }
 when(t.getFields()).thenReturn(f);
 when(t.getBinary(eq(MetadataUtil.KEY_INDEX))).thenReturn(metadata.getBytes());
 return t;
}

代码示例来源：origin: org.apache.storm/storm-hdfs

@Override
  public byte[] format(Tuple tuple) {
    StringBuilder sb = new StringBuilder();
    Fields fields = this.fields == null ? tuple.getFields() : this.fields;
    int size = fields.size();
    for(int i = 0; i < size; i++){
      sb.append(tuple.getValueByField(fields.get(i)));
      if(i != size - 1){
        sb.append(this.fieldDelimiter);
      }
    }
    sb.append(this.recordDelimiter);
    return sb.toString().getBytes();
  }
}

代码示例来源：origin: stackoverflow.com

@Test
public void testExecute() {
  Tuple t = mock(Tuple.class);
  when(t.getFields()).thenReturn(new Fields("myAttribute"));
  when(t.getValueByField("myAttribute").thenReturn("my json string to be tested");

  MyBolt b = new MyBolt();
  b.execute(t, mock(BasicOutputCollector.class));

  // put your assertions here
}

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

protected Result doWrite(Tuple tuple, Generator generator, String parentField) {
    Fields fields = tuple.getFields();

    generator.writeBeginObject();
    for (String field : fields) {
      if (shouldKeep(parentField, field)) {
        generator.writeFieldName(field);
        Object value = tuple.getValueByField(field);

        if (value instanceof Tuple) {
          Result result = write((Tuple) value, generator);
          if (!result.isSuccesful()) {
            return result;
          }
        }

        else {
          Result result = jdkWriter.write(value, generator);
          if (!result.isSuccesful()) {
            return result;
          }
        }
      }
    }
    generator.writeEndObject();
    return Result.SUCCESFUL();
  }
}