Package org.apache.avro

Examples of org.apache.avro.AvroRemoteException

224
225
226
227
228
229
230
    @Override
    public Status appendBatch(List<AvroFlumeEvent> events) throws
        AvroRemoteException {
      logger.log(Level.INFO, "Throwing: Received {0} events from appendBatch()",
          events.size());
      throw new AvroRemoteException("Handler smash!");
    }
View Full Code Here
107
108
109
110
111
112
113
114
115
      return future.get();
    } catch (ExecutionException e) {
      if (e.getCause() instanceof Exception) {
        throw (Exception)e.getCause();
      } else {
        throw new AvroRemoteException(e.getCause());
      }
    }
  }
View Full Code Here
153
154
155
156
157
158
159
160
161
162
163
            Throwable error = callFuture.getError();
            if (error != null) {
              if (error instanceof Exception) {
                throw (Exception) error;
              } else {
                throw new AvroRemoteException(error);
              }
            }
          }
          return;
        }
View Full Code Here
83
84
85
86
87
88
89
90
      if (e instanceof RuntimeException) {
        throw e;
      }
     
      // Not an expected Exception, so wrap it in AvroRemoteException:
      throw new AvroRemoteException(e);
    }
  }
View Full Code Here
47
48
49
50
51
52
53
54
    } catch (Exception e) {
      if (e instanceof RuntimeException)
        throw (RuntimeException)e;
      if (e instanceof IOException)
        throw (IOException)e;
      throw new AvroRemoteException(e);
    }
  }
View Full Code Here
61
62
63
64
65
66
67
68
    } catch (Exception e) {
      if (e instanceof RuntimeException)
        throw (RuntimeException)e;
      if (e instanceof IOException)
        throw (IOException)e;
      throw new AvroRemoteException(e);
    }
  }
View Full Code Here
83
84
85
86
87
88
89
  public Exception readError(Schema writer, Schema reader, Decoder in)
    throws IOException {
    Object error = new GenericDatumReader<Object>(writer, reader).read(null,in);
    if (error instanceof CharSequence)
      return new AvroRuntimeException(error.toString()); // system error
    return new AvroRemoteException(error);
  }
View Full Code Here
250
251
252
253
254
255
256
257
258
    public Object respond(Message message, Object request)
        throws AvroRemoteException {
      try {
        Thread.sleep((Long)((GenericRecord)request).get("millis"));
      } catch (InterruptedException e) {
        throw new AvroRemoteException(e);
      }
      return null;
    }
View Full Code Here
358
359
360
361
362
363
364
365
366
    public Object respond(Message message, Object request)
        throws AvroRemoteException {
      try {
        Thread.sleep((Long)((GenericRecord)request).get("millis"));
      } catch (InterruptedException e) {
        throw new AvroRemoteException(e);
      }
      return null;
    }
View Full Code Here
160
161
162
163
164
165
166
167
168
    public Object respond(Message message, Object request)
        throws AvroRemoteException {
      try {
        Thread.sleep((Long)((GenericRecord)request).get("millis"));
      } catch (InterruptedException e) {
        throw new AvroRemoteException(e);
      }
      return null;
    }
View Full Code Here
TOP

Related Classes of org.apache.avro.AvroRemoteException

  • co.cask.cdap.gateway.collector.FlumeAdapter
  • org.apache.avro.ipc.generic.GenericRequestor
  • org.apache.avro.ipc.Requestor
  • org.apache.avro.ipc.specific.SpecificRequestor
  • org.apache.avro.ipc.stats.TestStatsPluginAndServlet$SleepyResponder
  • org.apache.avro.ipc.trace.TestBasicTracing$SleepyResponder
  • org.apache.avro.ipc.trace.TestEndToEndTracing$SleepyResponder
  • org.apache.flume.api.RpcTestUtils$ThrowingAvroHandler
  • org.apache.flume.sink.AvroSink
  • org.apache.flume.sink.TestAvroSink$DelayMockAvroServer
    • Copyright © 2018 www.massapicom. All rights reserved.
    All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.