public static void readRowRanges() {
// TODO(developer): Replace these variables before running the sample.
String projectId = "my-project-id";
String instanceId = "my-instance-id";
String tableId = "mobile-time-series";
readRowRanges(projectId, instanceId, tableId);
}
public static void readRowRanges(String projectId, String instanceId, String tableId) {
// Initialize client that will be used to send requests. This client only needs to be created
// once, and can be reused for multiple requests. After completing all of your requests, call
// the "close" method on the client to safely clean up any remaining background resources.
try (Connection connection = BigtableConfiguration.connect(projectId, instanceId)) {
Table table = connection.getTable(TableName.valueOf(tableId));
List<RowRange> ranges = new ArrayList<>();
ranges.add(
new RowRange(
Bytes.toBytes("phone#4c410523#20190501"),
true,
Bytes.toBytes("phone#4c410523#20190601"),
false));
ranges.add(
new RowRange(
Bytes.toBytes("phone#5c10102#20190501"),
true,
Bytes.toBytes("phone#5c10102#20190601"),
false));
Filter filter = new MultiRowRangeFilter(ranges);
Scan scan = new Scan().setFilter(filter);
ResultScanner rows = table.getScanner(scan);
for (Result row : rows) {
printRow(row);
}
} catch (IOException e) {
System.out.println(
"Unable to initialize service client, as a network error occurred: \n" + e.toString());
}
}
