Skip to content

Commit e877ce2

Browse files
Maven spotless checks
1 parent 95dc90d commit e877ce2

25 files changed

+94
-156
lines changed

adapter/avro/src/main/java/org/apache/arrow/adapter/avro/ArrowToAvroUtils.java

Lines changed: 24 additions & 24 deletions
Original file line numberDiff line numberDiff line change
@@ -14,9 +14,10 @@
1414
* See the License for the specific language governing permissions and
1515
* limitations under the License.
1616
*/
17-
1817
package org.apache.arrow.adapter.avro;
1918

19+
import java.util.ArrayList;
20+
import java.util.List;
2021
import org.apache.arrow.adapter.avro.producers.AvroArraysProducer;
2122
import org.apache.arrow.adapter.avro.producers.AvroBooleanProducer;
2223
import org.apache.arrow.adapter.avro.producers.AvroBytesProducer;
@@ -41,8 +42,8 @@
4142
import org.apache.arrow.adapter.avro.producers.logical.AvroTimestampMicroProducer;
4243
import org.apache.arrow.adapter.avro.producers.logical.AvroTimestampMillisProducer;
4344
import org.apache.arrow.util.Preconditions;
44-
import org.apache.arrow.vector.BitVector;
4545
import org.apache.arrow.vector.BigIntVector;
46+
import org.apache.arrow.vector.BitVector;
4647
import org.apache.arrow.vector.DateDayVector;
4748
import org.apache.arrow.vector.DecimalVector;
4849
import org.apache.arrow.vector.FieldVector;
@@ -63,9 +64,6 @@
6364
import org.apache.arrow.vector.complex.UnionVector;
6465
import org.apache.arrow.vector.types.Types;
6566

66-
import java.util.ArrayList;
67-
import java.util.List;
68-
6967
public class ArrowToAvroUtils {
7068

7169
/**
@@ -76,14 +74,14 @@ public class ArrowToAvroUtils {
7674
*/
7775
public static CompositeAvroProducer createCompositeProducer(List<FieldVector> vectors) {
7876

79-
List<Producer<? extends FieldVector>> producers = new ArrayList<>(vectors.size());
77+
List<Producer<? extends FieldVector>> producers = new ArrayList<>(vectors.size());
8078

81-
for (FieldVector vector : vectors) {
82-
BaseAvroProducer<? extends FieldVector> producer = createProducer(vector);
83-
producers.add(producer);
84-
}
79+
for (FieldVector vector : vectors) {
80+
BaseAvroProducer<? extends FieldVector> producer = createProducer(vector);
81+
producers.add(producer);
82+
}
8583

86-
return new CompositeAvroProducer(producers);
84+
return new CompositeAvroProducer(producers);
8785
}
8886

8987
private static BaseAvroProducer<?> createProducer(FieldVector vector) {
@@ -106,7 +104,7 @@ private static BaseAvroProducer<?> createProducer(FieldVector vector, boolean nu
106104

107105
switch (minorType) {
108106

109-
// Primitive types with direct mapping to Avro
107+
// Primitive types with direct mapping to Avro
110108

111109
case NULL:
112110
return new AvroNullProducer((NullVector) vector);
@@ -127,10 +125,11 @@ private static BaseAvroProducer<?> createProducer(FieldVector vector, boolean nu
127125
case VARCHAR:
128126
return new AvroStringProducer((VarCharVector) vector);
129127

130-
// Logical types
128+
// Logical types
131129

132130
case DECIMAL:
133-
return new AvroDecimalProducer.FixedDecimalProducer((DecimalVector) vector, DecimalVector.TYPE_WIDTH);
131+
return new AvroDecimalProducer.FixedDecimalProducer(
132+
(DecimalVector) vector, DecimalVector.TYPE_WIDTH);
134133
case DATEDAY:
135134
return new AvroDateProducer((DateDayVector) vector);
136135
case TIMEMILLI:
@@ -142,10 +141,9 @@ private static BaseAvroProducer<?> createProducer(FieldVector vector, boolean nu
142141
case TIMESTAMPMICRO:
143142
return new AvroTimestampMicroProducer((TimeStampMicroVector) vector);
144143

145-
// Complex types
144+
// Complex types
146145

147146
case STRUCT:
148-
149147
StructVector structVector = (StructVector) vector;
150148
List<FieldVector> childVectors = structVector.getChildrenFromFields();
151149
Producer<?>[] childProducers = new Producer<?>[childVectors.size()];
@@ -156,38 +154,40 @@ private static BaseAvroProducer<?> createProducer(FieldVector vector, boolean nu
156154
return new AvroStructProducer(structVector, childProducers);
157155

158156
case LIST:
159-
160157
ListVector listVector = (ListVector) vector;
161158
FieldVector itemVector = listVector.getDataVector();
162159
Producer<?> itemProducer = createProducer(itemVector, itemVector.getField().isNullable());
163160
return new AvroArraysProducer(listVector, itemProducer);
164161

165162
case MAP:
166-
167163
MapVector mapVector = (MapVector) vector;
168164
StructVector entryVector = (StructVector) mapVector.getDataVector();
169165
VarCharVector keyVector = (VarCharVector) entryVector.getChildrenFromFields().get(0);
170166
FieldVector valueVector = entryVector.getChildrenFromFields().get(1);
171167
Producer<?> keyProducer = new AvroStringProducer(keyVector);
172-
Producer<?> valueProducer = createProducer(valueVector, valueVector.getField().isNullable());
173-
Producer<?> entryProducer = new AvroStructProducer(entryVector, new Producer<?>[] {keyProducer, valueProducer});
168+
Producer<?> valueProducer =
169+
createProducer(valueVector, valueVector.getField().isNullable());
170+
Producer<?> entryProducer =
171+
new AvroStructProducer(entryVector, new Producer<?>[] {keyProducer, valueProducer});
174172
return new AvroMapProducer(mapVector, entryProducer);
175173

176174
case UNION:
177-
178175
UnionVector unionVector = (UnionVector) vector;
179176
List<FieldVector> unionChildVectors = unionVector.getChildrenFromFields();
180177
Producer<?>[] unionChildProducers = new Producer<?>[unionChildVectors.size()];
181178
for (int i = 0; i < unionChildVectors.size(); i++) {
182179
FieldVector unionChildVector = unionChildVectors.get(i);
183-
unionChildProducers[i] = createProducer(unionChildVector, /* nullable = */ false); // Do not nest union types
180+
unionChildProducers[i] =
181+
createProducer(unionChildVector, /* nullable = */ false); // Do not nest union types
184182
}
185183
return new AvroUnionsProducer(unionVector, unionChildProducers);
186184

187-
// Not all Arrow types are supported for encoding (yet)!
185+
// Not all Arrow types are supported for encoding (yet)!
188186

189187
default:
190-
String error = String.format("Encoding Arrow type %s to Avro is not currently supported", minorType.name());
188+
String error =
189+
String.format(
190+
"Encoding Arrow type %s to Avro is not currently supported", minorType.name());
191191
throw new UnsupportedOperationException(error);
192192
}
193193
}

adapter/avro/src/main/java/org/apache/arrow/adapter/avro/producers/AvroArraysProducer.java

Lines changed: 2 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -14,18 +14,16 @@
1414
* See the License for the specific language governing permissions and
1515
* limitations under the License.
1616
*/
17-
1817
package org.apache.arrow.adapter.avro.producers;
1918

2019
import java.io.IOException;
21-
2220
import org.apache.arrow.vector.FieldVector;
2321
import org.apache.arrow.vector.complex.ListVector;
2422
import org.apache.avro.io.Encoder;
2523

2624
/**
27-
* Producer which produces array type values to an Avro encoder.
28-
* Writes the data from a {@link ListVector}.
25+
* Producer which produces array type values to an Avro encoder. Writes the data from a {@link
26+
* ListVector}.
2927
*/
3028
public class AvroArraysProducer extends BaseAvroProducer<ListVector> {
3129

adapter/avro/src/main/java/org/apache/arrow/adapter/avro/producers/AvroBooleanProducer.java

Lines changed: 2 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -17,19 +17,15 @@
1717
package org.apache.arrow.adapter.avro.producers;
1818

1919
import java.io.IOException;
20-
2120
import org.apache.arrow.vector.BitVector;
2221
import org.apache.avro.io.Encoder;
2322

2423
/**
25-
* Producer that produces boolean values from a {@link BitVector},
26-
* writes data to an Avro encoder.
24+
* Producer that produces boolean values from a {@link BitVector}, writes data to an Avro encoder.
2725
*/
2826
public class AvroBooleanProducer extends BaseAvroProducer<BitVector> {
2927

30-
/**
31-
* Instantiate am AvroBooleanProducer.
32-
*/
28+
/** Instantiate am AvroBooleanProducer. */
3329
public AvroBooleanProducer(BitVector vector) {
3430
super(vector);
3531
}

adapter/avro/src/main/java/org/apache/arrow/adapter/avro/producers/AvroBytesProducer.java

Lines changed: 3 additions & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -14,24 +14,20 @@
1414
* See the License for the specific language governing permissions and
1515
* limitations under the License.
1616
*/
17-
1817
package org.apache.arrow.adapter.avro.producers;
1918

2019
import java.io.IOException;
2120
import java.nio.ByteBuffer;
22-
2321
import org.apache.arrow.vector.VarBinaryVector;
2422
import org.apache.avro.io.Encoder;
2523

2624
/**
27-
* Producer that produces byte array values from a {@link VarBinaryVector},
28-
* writes data to an Avro encoder.
25+
* Producer that produces byte array values from a {@link VarBinaryVector}, writes data to an Avro
26+
* encoder.
2927
*/
3028
public class AvroBytesProducer extends BaseAvroProducer<VarBinaryVector> {
3129

32-
/**
33-
* Instantiate an AvroBytesProducer.
34-
*/
30+
/** Instantiate an AvroBytesProducer. */
3531
public AvroBytesProducer(VarBinaryVector vector) {
3632
super(vector);
3733
}

adapter/avro/src/main/java/org/apache/arrow/adapter/avro/producers/AvroDoubleProducer.java

Lines changed: 2 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -17,19 +17,15 @@
1717
package org.apache.arrow.adapter.avro.producers;
1818

1919
import java.io.IOException;
20-
2120
import org.apache.arrow.vector.Float8Vector;
2221
import org.apache.avro.io.Encoder;
2322

2423
/**
25-
* Producer that produces double values from a {@link Float8Vector},
26-
* writes data to an Avro encoder.
24+
* Producer that produces double values from a {@link Float8Vector}, writes data to an Avro encoder.
2725
*/
2826
public class AvroDoubleProducer extends BaseAvroProducer<Float8Vector> {
2927

30-
/**
31-
* Instantiate an AvroDoubleProducer.
32-
*/
28+
/** Instantiate an AvroDoubleProducer. */
3329
public AvroDoubleProducer(Float8Vector vector) {
3430
super(vector);
3531
}

adapter/avro/src/main/java/org/apache/arrow/adapter/avro/producers/AvroEnumProducer.java

Lines changed: 2 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -14,17 +14,15 @@
1414
* See the License for the specific language governing permissions and
1515
* limitations under the License.
1616
*/
17-
1817
package org.apache.arrow.adapter.avro.producers;
1918

2019
import java.io.IOException;
21-
2220
import org.apache.arrow.vector.IntVector;
2321
import org.apache.avro.io.Encoder;
2422

2523
/**
26-
* Producer that produces enum values from a dictionary-encoded {@link IntVector},
27-
* writes data to an Avro encoder.
24+
* Producer that produces enum values from a dictionary-encoded {@link IntVector}, writes data to an
25+
* Avro encoder.
2826
*/
2927
public class AvroEnumProducer extends BaseAvroProducer<IntVector> {
3028

adapter/avro/src/main/java/org/apache/arrow/adapter/avro/producers/AvroFixedProducer.java

Lines changed: 3 additions & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -14,25 +14,21 @@
1414
* See the License for the specific language governing permissions and
1515
* limitations under the License.
1616
*/
17-
1817
package org.apache.arrow.adapter.avro.producers;
1918

2019
import java.io.IOException;
21-
2220
import org.apache.arrow.vector.FixedSizeBinaryVector;
2321
import org.apache.avro.io.Encoder;
2422

2523
/**
26-
* Producer that produces fixed-size binary values from a {@link FixedSizeBinaryVector},
27-
* writes data to an Avro encoder.
24+
* Producer that produces fixed-size binary values from a {@link FixedSizeBinaryVector}, writes data
25+
* to an Avro encoder.
2826
*/
2927
public class AvroFixedProducer extends BaseAvroProducer<FixedSizeBinaryVector> {
3028

3129
private final byte[] reuseBytes;
3230

33-
/**
34-
* Instantiate an AvroFixedProducer.
35-
*/
31+
/** Instantiate an AvroFixedProducer. */
3632
public AvroFixedProducer(FixedSizeBinaryVector vector) {
3733
super(vector);
3834
reuseBytes = new byte[vector.getByteWidth()];

adapter/avro/src/main/java/org/apache/arrow/adapter/avro/producers/AvroFloatProducer.java

Lines changed: 2 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -17,19 +17,15 @@
1717
package org.apache.arrow.adapter.avro.producers;
1818

1919
import java.io.IOException;
20-
2120
import org.apache.arrow.vector.Float4Vector;
2221
import org.apache.avro.io.Encoder;
2322

2423
/**
25-
* Producer that produces float values from a {@link Float4Vector},
26-
* writes data to an Avro encoder.
24+
* Producer that produces float values from a {@link Float4Vector}, writes data to an Avro encoder.
2725
*/
2826
public class AvroFloatProducer extends BaseAvroProducer<Float4Vector> {
2927

30-
/**
31-
* Instantiate an AvroFloatProducer.
32-
*/
28+
/** Instantiate an AvroFloatProducer. */
3329
public AvroFloatProducer(Float4Vector vector) {
3430
super(vector);
3531
}

adapter/avro/src/main/java/org/apache/arrow/adapter/avro/producers/AvroIntProducer.java

Lines changed: 3 additions & 9 deletions
Original file line numberDiff line numberDiff line change
@@ -16,20 +16,14 @@
1616
*/
1717
package org.apache.arrow.adapter.avro.producers;
1818

19+
import java.io.IOException;
1920
import org.apache.arrow.vector.IntVector;
2021
import org.apache.avro.io.Encoder;
2122

22-
import java.io.IOException;
23-
24-
/**
25-
* Producer that produces int values from an {@link IntVector},
26-
* writes data to an avro encoder.
27-
*/
23+
/** Producer that produces int values from an {@link IntVector}, writes data to an avro encoder. */
2824
public class AvroIntProducer extends BaseAvroProducer<IntVector> {
2925

30-
/**
31-
* Instantiate an AvroIntConsumer.
32-
*/
26+
/** Instantiate an AvroIntConsumer. */
3327
public AvroIntProducer(IntVector vector) {
3428
super(vector);
3529
}

adapter/avro/src/main/java/org/apache/arrow/adapter/avro/producers/AvroLongProducer.java

Lines changed: 2 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -17,19 +17,15 @@
1717
package org.apache.arrow.adapter.avro.producers;
1818

1919
import java.io.IOException;
20-
2120
import org.apache.arrow.vector.BigIntVector;
2221
import org.apache.avro.io.Encoder;
2322

2423
/**
25-
* Producer that produces long values from a {@link BigIntVector},
26-
* writes data to an Avro encoder.
24+
* Producer that produces long values from a {@link BigIntVector}, writes data to an Avro encoder.
2725
*/
2826
public class AvroLongProducer extends BaseAvroProducer<BigIntVector> {
2927

30-
/**
31-
* Instantiate an AvroLongProducer.
32-
*/
28+
/** Instantiate an AvroLongProducer. */
3329
public AvroLongProducer(BigIntVector vector) {
3430
super(vector);
3531
}

0 commit comments

Comments
 (0)