@@ -89,7 +89,7 @@ public String getCompressorName() {
8989 }
9090
9191 /**
92- * Returns the wait for ready flag
92+ * Returns the wait for ready flag.
9393 *
9494 * @return the wait for ready flag
9595 */
@@ -130,8 +130,10 @@ public CallOption[] getCallOptionCallback() {
130130 }
131131
132132 @ Override
133- public boolean equals (Object o ) {
134- if (o == null || getClass () != o .getClass ()) return false ;
133+ public boolean equals (final Object o ) {
134+ if (o == null || getClass () != o .getClass ()) {
135+ return false ;
136+ }
135137 GrpcCallOption that = (GrpcCallOption ) o ;
136138 return Objects .equals (deadLineAfter , that .deadLineAfter )
137139 && Objects .equals (executor , that .executor )
@@ -154,14 +156,15 @@ public int hashCode() {
154156
155157 @ Override
156158 public String toString () {
157- return "GrpcCallOption{" +
158- "deadLineAfter=" + deadLineAfter +
159- ", executor=" + executor +
160- ", compressorName='" + compressorName + '\'' +
161- ", waitForReady=" + waitForReady +
162- ", maxInboundMessageSize=" + maxInboundMessageSize +
163- ", maxOutboundMessageSize=" + maxOutboundMessageSize +
164- '}' ;
159+ return "GrpcCallOption{"
160+ + "deadLineAfter=" + deadLineAfter
161+ + ", executor=" + executor
162+ + ", compressorName='" + compressorName
163+ + '\''
164+ + ", waitForReady=" + waitForReady
165+ + ", maxInboundMessageSize=" + maxInboundMessageSize
166+ + ", maxOutboundMessageSize=" + maxOutboundMessageSize
167+ + '}' ;
165168 }
166169
167170 public static final class Builder {
@@ -183,7 +186,7 @@ public static final class Builder {
183186 public Builder withDeadlineAfter (final long duration , @ Nonnull final TimeUnit timeUnit ) {
184187 var callOption = new org .apache .arrow .flight .CallOptions .GrpcCallOption () {
185188 @ Override
186- public <T extends AbstractStub <T >> T wrapStub (T stub ) {
189+ public <T extends AbstractStub <T >> T wrapStub (final T stub ) {
187190 return stub .withDeadlineAfter (duration , timeUnit );
188191 }
189192 };
@@ -201,7 +204,7 @@ public <T extends AbstractStub<T>> T wrapStub(T stub) {
201204 public Builder withExecutor (@ Nonnull final Executor executor ) {
202205 var callOption = new org .apache .arrow .flight .CallOptions .GrpcCallOption () {
203206 @ Override
204- public <T extends AbstractStub <T >> T wrapStub (T stub ) {
207+ public <T extends AbstractStub <T >> T wrapStub (final T stub ) {
205208 return stub .withExecutor (executor );
206209 }
207210 };
@@ -223,7 +226,7 @@ public <T extends AbstractStub<T>> T wrapStub(T stub) {
223226 public Builder withCompressorName (@ Nonnull final String compressorName ) {
224227 var callOption = new org .apache .arrow .flight .CallOptions .GrpcCallOption () {
225228 @ Override
226- public <T extends AbstractStub <T >> T wrapStub (T stub ) {
229+ public <T extends AbstractStub <T >> T wrapStub (final T stub ) {
227230 return stub .withCompression (compressorName );
228231 }
229232 };
@@ -243,7 +246,7 @@ public <T extends AbstractStub<T>> T wrapStub(T stub) {
243246 public Builder withWaitForReady () {
244247 var callOption = new org .apache .arrow .flight .CallOptions .GrpcCallOption () {
245248 @ Override
246- public <T extends AbstractStub <T >> T wrapStub (T stub ) {
249+ public <T extends AbstractStub <T >> T wrapStub (final T stub ) {
247250 return stub .withWaitForReady ();
248251 }
249252 };
@@ -261,7 +264,7 @@ public <T extends AbstractStub<T>> T wrapStub(T stub) {
261264 public Builder withMaxInboundMessageSize (@ Nonnull final Integer maxInboundMessageSize ) {
262265 var callOption = new org .apache .arrow .flight .CallOptions .GrpcCallOption () {
263266 @ Override
264- public <T extends AbstractStub <T >> T wrapStub (T stub ) {
267+ public <T extends AbstractStub <T >> T wrapStub (final T stub ) {
265268 return stub .withMaxInboundMessageSize (maxInboundMessageSize );
266269 }
267270 };
@@ -278,7 +281,7 @@ public <T extends AbstractStub<T>> T wrapStub(T stub) {
278281 public Builder withMaxOutboundMessageSize (@ Nonnull final Integer maxOutboundMessageSize ) {
279282 var callOption = new org .apache .arrow .flight .CallOptions .GrpcCallOption () {
280283 @ Override
281- public <T extends AbstractStub <T >> T wrapStub (T stub ) {
284+ public <T extends AbstractStub <T >> T wrapStub (final T stub ) {
282285 return stub .withMaxOutboundMessageSize (maxOutboundMessageSize );
283286 }
284287 };
0 commit comments