@Test public void testLengthIsSerialized() throws Exception { TableSplit split1 = new TableSplit(TableName.valueOf("table"), "row-start".getBytes(), "row-end".getBytes(), "location", 666); TableSplit deserialized = new TableSplit(TableName.valueOf("table"), "row-start2".getBytes(), "row-end2".getBytes(), "location1"); ReflectionUtils.copy(new Configuration(), split1, deserialized); Assert.assertEquals(666, deserialized.getLength()); }
@Override public long getLength() { return length; }
TableSplit extends InputSplit implements Writable, Comparable<TableSplit> { @Override public long getLength() { return length; } }
TableSplit extends InputSplit implements Writable, Comparable<TableSplit> { @Override public long getLength() { return length; } TableSplit(); @Deprecated  TableSplit(final byte [] tableName, Scan scan, byte [] startRow, byte [] endRow,
      final String location);  TableSplit(TableName tableName, Scan scan, byte [] startRow, byte [] endRow,
                    final String location);  TableSplit(TableName tableName, Scan scan, byte [] startRow, byte [] endRow,
      final String location, long length); @Deprecated  TableSplit(final byte [] tableName, byte[] startRow, byte[] endRow,
      final String location);  TableSplit(TableName tableName, byte[] startRow, byte[] endRow,
      final String location);  TableSplit(TableName tableName, byte[] startRow, byte[] endRow,
                    final String location, long length); }
TableSplit extends InputSplit implements Writable, Comparable<TableSplit> { @Override public long getLength() { return length; } TableSplit(); @Deprecated  TableSplit(final byte [] tableName, Scan scan, byte [] startRow, byte [] endRow,
      final String location);  TableSplit(TableName tableName, Scan scan, byte [] startRow, byte [] endRow,
                    final String location);  TableSplit(TableName tableName, Scan scan, byte [] startRow, byte [] endRow,
      final String location, long length); @Deprecated  TableSplit(final byte [] tableName, byte[] startRow, byte[] endRow,
      final String location);  TableSplit(TableName tableName, byte[] startRow, byte[] endRow,
      final String location);  TableSplit(TableName tableName, byte[] startRow, byte[] endRow,
                    final String location, long length); Scan getScan(); byte [] getTableName(); TableName getTable(); byte [] getStartRow(); byte [] getEndRow(); String getRegionLocation(); @Override String[] getLocations(); @Override long getLength(); @Override void readFields(DataInput in); @Override void write(DataOutput out); @Override String toString(); @Override int compareTo(TableSplit split); @Override boolean equals(Object o); @Override int hashCode(); }
TableSplit extends InputSplit implements Writable, Comparable<TableSplit> { @Override public long getLength() { return length; } TableSplit(); @Deprecated  TableSplit(final byte [] tableName, Scan scan, byte [] startRow, byte [] endRow,
      final String location);  TableSplit(TableName tableName, Scan scan, byte [] startRow, byte [] endRow,
                    final String location);  TableSplit(TableName tableName, Scan scan, byte [] startRow, byte [] endRow,
      final String location, long length); @Deprecated  TableSplit(final byte [] tableName, byte[] startRow, byte[] endRow,
      final String location);  TableSplit(TableName tableName, byte[] startRow, byte[] endRow,
      final String location);  TableSplit(TableName tableName, byte[] startRow, byte[] endRow,
                    final String location, long length); Scan getScan(); byte [] getTableName(); TableName getTable(); byte [] getStartRow(); byte [] getEndRow(); String getRegionLocation(); @Override String[] getLocations(); @Override long getLength(); @Override void readFields(DataInput in); @Override void write(DataOutput out); @Override String toString(); @Override int compareTo(TableSplit split); @Override boolean equals(Object o); @Override int hashCode(); static final Log LOG; }