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

State.readFields介绍

暂无

代码示例

代码示例来源：origin: apache/incubator-gobblin

/**
  * Deserialize/read a {@link State} instance from a file.
  *
  * @param is {@link InputStream} containing the state.
  * @param state an empty {@link State} instance to deserialize into
  * @param <T> the {@link State} object type
  * @throws IOException if it fails to deserialize the {@link State} instance
  */
 public static <T extends State> void deserializeStateFromInputStream(InputStream is, T state) throws IOException {
  try (DataInputStream dis = (new DataInputStream(is))) {
   state.readFields(dis);
  }
 }
}

代码示例来源：origin: apache/incubator-gobblin

@Override
public void readFields(DataInput in) throws IOException {
 this.workUnit.readFields(in);
 super.readFields(in);
}

代码示例来源：origin: apache/incubator-gobblin

@Override
public void readFields(DataInput in) throws IOException {
 super.readFields(in);
 this.extract.readFields(in);
}

代码示例来源：origin: apache/incubator-gobblin

private static State loadState (FileSystem fs, Path dir) throws IOException {
 State state = new State();
 if (fs.exists(new Path(dir, STATE_FILE))) {
  try (FSDataInputStream inputStream = fs.open(new Path(dir, STATE_FILE))) {
   state.readFields(inputStream);
  }
 }
 return state;
}

代码示例来源：origin: apache/incubator-gobblin

T state = this.stateClass.newInstance();
key.readString(dis);
state.readFields(dis);
states.add(state);

代码示例来源：origin: apache/incubator-gobblin

state.readFields(dis);
states.add(state);

代码示例来源：origin: apache/incubator-gobblin

@Override
public void readFields(DataInput in)
  throws IOException {
 int size = in.readInt();
 for (int i = 0; i < size; i++) {
  WorkUnitState workUnitState = new WorkUnitState();
  workUnitState.readFields(in);
  this.previousWorkUnitStates.add(new ImmutableWorkUnitState(workUnitState));
 }
 super.readFields(in);
}

代码示例来源：origin: apache/incubator-gobblin

state.readFields(dis);

代码示例来源：origin: apache/incubator-gobblin

@Test
public void testInterningOfKeyValues() throws Exception {
 // Prove we can identify interned keys
 String nonInterned = new String("myKey"); // not interned
 String interned = new String("myInternedKey").intern(); // interned
 Assert.assertFalse(isInterned(nonInterned));
 Assert.assertTrue(isInterned(interned));
 State state = new State();
 state.setProp(new String("someKey"), new String("someValue"));
 ByteArrayOutputStream outputStream = new ByteArrayOutputStream();
 DataOutput dataOutput = new DataOutputStream(outputStream);
 state.write(dataOutput);
 outputStream.flush();
 ByteArrayInputStream inputStream = new ByteArrayInputStream(outputStream.toByteArray());
 DataInput dataInput = new DataInputStream(inputStream);
 State readState = new State();
 readState.readFields(dataInput);
 inputStream.close();
 Assert.assertEquals(state, readState);
 assertInterned(state.getProperties(), false);
 assertInterned(readState.getProperties(), true);
}

代码示例来源：origin: apache/incubator-gobblin

Assert.assertEquals(state.getProp("boolean"), null);
state.readFields(in);

代码示例来源：origin: org.apache.gobblin/gobblin-utility

/**
  * Deserialize/read a {@link State} instance from a file.
  *
  * @param is {@link InputStream} containing the state.
  * @param state an empty {@link State} instance to deserialize into
  * @param <T> the {@link State} object type
  * @throws IOException if it fails to deserialize the {@link State} instance
  */
 public static <T extends State> void deserializeStateFromInputStream(InputStream is, T state) throws IOException {
  try (DataInputStream dis = (new DataInputStream(is))) {
   state.readFields(dis);
  }
 }
}

代码示例来源：origin: org.apache.gobblin/gobblin-api

@Override
public void readFields(DataInput in) throws IOException {
 super.readFields(in);
 this.extract.readFields(in);
}

代码示例来源：origin: org.apache.gobblin/gobblin-api

@Override
public void readFields(DataInput in) throws IOException {
 this.workUnit.readFields(in);
 super.readFields(in);
}

代码示例来源：origin: org.apache.gobblin/gobblin-compaction

private static State loadState (FileSystem fs, Path dir) throws IOException {
 State state = new State();
 if (fs.exists(new Path(dir, STATE_FILE))) {
  try (FSDataInputStream inputStream = fs.open(new Path(dir, STATE_FILE))) {
   state.readFields(inputStream);
  }
 }
 return state;
}

代码示例来源：origin: org.apache.gobblin/gobblin-api

@Override
public void readFields(DataInput in)
  throws IOException {
 int size = in.readInt();
 for (int i = 0; i < size; i++) {
  WorkUnitState workUnitState = new WorkUnitState();
  workUnitState.readFields(in);
  this.previousWorkUnitStates.add(new ImmutableWorkUnitState(workUnitState));
 }
 super.readFields(in);
}

代码示例来源：origin: org.apache.gobblin/gobblin-metastore

T state = this.stateClass.newInstance();
key.readString(dis);
state.readFields(dis);
states.add(state);

代码示例来源：origin: org.apache.gobblin/gobblin-metastore

state.readFields(dis);