This is an automated email from the ASF dual-hosted git repository.
blue pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/incubator-iceberg.git
The following commit(s) were added to refs/heads/master by this push:
new d8dfb27 Use only guava Preconditions (#911)
d8dfb27 is described below
commit d8dfb2711b7a320dca66b09e058f1ceac25dd25d
Author: Xuedong Luan <[email protected]>
AuthorDate: Sat Apr 11 00:51:17 2020 +0800
Use only guava Preconditions (#911)
Co-authored-by: Luan <[email protected]>
---
.../vectorized/parquet/BaseVectorizedParquetValuesReader.java | 2 +-
.../arrow/vectorized/parquet/VectorizedColumnIterator.java | 2 +-
.../main/java/org/apache/iceberg/parquet/MessageTypeToType.java | 8 ++++----
.../main/java/org/apache/iceberg/spark/source/BaseDataReader.java | 2 +-
4 files changed, 7 insertions(+), 7 deletions(-)
diff --git
a/arrow/src/main/java/org/apache/iceberg/arrow/vectorized/parquet/BaseVectorizedParquetValuesReader.java
b/arrow/src/main/java/org/apache/iceberg/arrow/vectorized/parquet/BaseVectorizedParquetValuesReader.java
index a0aea66..e2292b2 100644
---
a/arrow/src/main/java/org/apache/iceberg/arrow/vectorized/parquet/BaseVectorizedParquetValuesReader.java
+++
b/arrow/src/main/java/org/apache/iceberg/arrow/vectorized/parquet/BaseVectorizedParquetValuesReader.java
@@ -19,9 +19,9 @@
package org.apache.iceberg.arrow.vectorized.parquet;
+import com.google.common.base.Preconditions;
import java.io.IOException;
import java.nio.ByteBuffer;
-import org.apache.parquet.Preconditions;
import org.apache.parquet.bytes.ByteBufferInputStream;
import org.apache.parquet.bytes.BytesUtils;
import org.apache.parquet.column.values.ValuesReader;
diff --git
a/arrow/src/main/java/org/apache/iceberg/arrow/vectorized/parquet/VectorizedColumnIterator.java
b/arrow/src/main/java/org/apache/iceberg/arrow/vectorized/parquet/VectorizedColumnIterator.java
index e2fd05c..d0d0583 100644
---
a/arrow/src/main/java/org/apache/iceberg/arrow/vectorized/parquet/VectorizedColumnIterator.java
+++
b/arrow/src/main/java/org/apache/iceberg/arrow/vectorized/parquet/VectorizedColumnIterator.java
@@ -19,7 +19,7 @@
package org.apache.iceberg.arrow.vectorized.parquet;
-import org.apache.arrow.util.Preconditions;
+import com.google.common.base.Preconditions;
import org.apache.arrow.vector.FieldVector;
import org.apache.arrow.vector.IntVector;
import org.apache.iceberg.arrow.vectorized.NullabilityHolder;
diff --git
a/parquet/src/main/java/org/apache/iceberg/parquet/MessageTypeToType.java
b/parquet/src/main/java/org/apache/iceberg/parquet/MessageTypeToType.java
index 717f87f..ffdbc17 100644
--- a/parquet/src/main/java/org/apache/iceberg/parquet/MessageTypeToType.java
+++ b/parquet/src/main/java/org/apache/iceberg/parquet/MessageTypeToType.java
@@ -20,13 +20,13 @@
package org.apache.iceberg.parquet;
import com.google.common.base.Joiner;
+import com.google.common.base.Preconditions;
import com.google.common.collect.Lists;
import com.google.common.collect.Maps;
import java.util.List;
import java.util.Map;
import org.apache.iceberg.types.Type;
import org.apache.iceberg.types.Types;
-import org.apache.parquet.Preconditions;
import org.apache.parquet.schema.DecimalMetadata;
import org.apache.parquet.schema.GroupType;
import org.apache.parquet.schema.MessageType;
@@ -71,7 +71,7 @@ class MessageTypeToType extends ParquetTypeVisitor<Type> {
Preconditions.checkArgument(
!field.isRepetition(Repetition.REPEATED),
- "Fields cannot have repetition REPEATED: {}", field);
+ "Fields cannot have repetition REPEATED: %s", field);
int fieldId = getId(field);
@@ -94,7 +94,7 @@ class MessageTypeToType extends ParquetTypeVisitor<Type> {
Preconditions.checkArgument(
!element.isRepetition(Repetition.REPEATED),
- "Elements cannot have repetition REPEATED: {}", element);
+ "Elements cannot have repetition REPEATED: %s", element);
int elementFieldId = getId(element);
@@ -115,7 +115,7 @@ class MessageTypeToType extends ParquetTypeVisitor<Type> {
Preconditions.checkArgument(
!value.isRepetition(Repetition.REPEATED),
- "Values cannot have repetition REPEATED: {}", value);
+ "Values cannot have repetition REPEATED: %s", value);
int keyFieldId = getId(key);
int valueFieldId = getId(value);
diff --git
a/spark/src/main/java/org/apache/iceberg/spark/source/BaseDataReader.java
b/spark/src/main/java/org/apache/iceberg/spark/source/BaseDataReader.java
index 1e3e07f..fab6680 100644
--- a/spark/src/main/java/org/apache/iceberg/spark/source/BaseDataReader.java
+++ b/spark/src/main/java/org/apache/iceberg/spark/source/BaseDataReader.java
@@ -19,6 +19,7 @@
package org.apache.iceberg.spark.source;
+import com.google.common.base.Preconditions;
import com.google.common.collect.ImmutableMap;
import com.google.common.collect.Iterables;
import java.io.Closeable;
@@ -26,7 +27,6 @@ import java.io.IOException;
import java.util.Collections;
import java.util.Iterator;
import java.util.Map;
-import org.apache.arrow.util.Preconditions;
import org.apache.iceberg.CombinedScanTask;
import org.apache.iceberg.FileScanTask;
import org.apache.iceberg.encryption.EncryptedFiles;