Skip to content

Commit a4574e0

Browse files
committed
Updating dataset reader examples to use for-each.
1 parent 93238c2 commit a4574e0

File tree

4 files changed

+4
-8
lines changed

4 files changed

+4
-8
lines changed

dataset/src/main/java/com/cloudera/cdk/examples/data/ReadHCatalogUserDatasetGeneric.java

Lines changed: 1 addition & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -42,8 +42,7 @@ public int run(String[] args) throws Exception {
4242
DatasetReader<GenericRecord> reader = users.getReader();
4343
try {
4444
reader.open();
45-
while (reader.hasNext()) {
46-
GenericRecord user = reader.read();
45+
for (GenericRecord user : reader) {
4746
System.out.println(user);
4847
}
4948
} finally {

dataset/src/main/java/com/cloudera/cdk/examples/data/ReadProductDatasetPojo.java

Lines changed: 1 addition & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -43,8 +43,7 @@ public int run(String[] args) throws Exception {
4343
DatasetReader<Product> reader = products.getReader();
4444
try {
4545
reader.open();
46-
while (reader.hasNext()) {
47-
Product product = reader.read();
46+
for (Product product : reader) {
4847
System.out.println(product);
4948
}
5049
} finally {

dataset/src/main/java/com/cloudera/cdk/examples/data/ReadUserDatasetGeneric.java

Lines changed: 1 addition & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -44,8 +44,7 @@ public int run(String[] args) throws Exception {
4444
DatasetReader<GenericRecord> reader = users.getReader();
4545
try {
4646
reader.open();
47-
while (reader.hasNext()) {
48-
GenericRecord user = reader.read();
47+
for (GenericRecord user : reader) {
4948
System.out.println(user);
5049
}
5150
} finally {

dataset/src/main/java/com/cloudera/cdk/examples/data/ReadUserDatasetGenericOnePartition.java

Lines changed: 1 addition & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -54,8 +54,7 @@ public int run(String[] args) throws Exception {
5454
DatasetReader<GenericRecord> reader = partition.getReader();
5555
try {
5656
reader.open();
57-
while (reader.hasNext()) {
58-
GenericRecord user = reader.read();
57+
for (GenericRecord user : reader) {
5958
System.out.println(user);
6059
}
6160
} finally {

0 commit comments

Comments
 (0)