@Test public void testSelectInvalid() { thrown.expect(IllegalArgumentException.class); thrown.expectMessage("Invalid value 'foo' for S3_SELECT option"); context.setFormat("CSV"); context.addOption("S3_SELECT", "foo"); handler.getAccessorClassName(context); }
@Override public String getAccessorClassName(RequestContext context) { String accessor = context.getAccessor(); if (useS3Select(context)) { accessor = S3SelectAccessor.class.getName(); } LOG.debug("Determined to use {} accessor", accessor); return accessor; }
S3ProtocolHandler implements ProtocolHandler { @Override public String getAccessorClassName(RequestContext context) { String accessor = context.getAccessor(); if (useS3Select(context)) { accessor = S3SelectAccessor.class.getName(); } LOG.debug("Determined to use {} accessor", accessor); return accessor; } }
S3ProtocolHandler implements ProtocolHandler { @Override public String getAccessorClassName(RequestContext context) { String accessor = context.getAccessor(); if (useS3Select(context)) { accessor = S3SelectAccessor.class.getName(); } LOG.debug("Determined to use {} accessor", accessor); return accessor; }  }
S3ProtocolHandler implements ProtocolHandler { @Override public String getAccessorClassName(RequestContext context) { String accessor = context.getAccessor(); if (useS3Select(context)) { accessor = S3SelectAccessor.class.getName(); } LOG.debug("Determined to use {} accessor", accessor); return accessor; }  @Override String getFragmenterClassName(RequestContext context); @Override String getAccessorClassName(RequestContext context); @Override String getResolverClassName(RequestContext context); }
S3ProtocolHandler implements ProtocolHandler { @Override public String getAccessorClassName(RequestContext context) { String accessor = context.getAccessor(); if (useS3Select(context)) { accessor = S3SelectAccessor.class.getName(); } LOG.debug("Determined to use {} accessor", accessor); return accessor; }  @Override String getFragmenterClassName(RequestContext context); @Override String getAccessorClassName(RequestContext context); @Override String getResolverClassName(RequestContext context); static final String S3_SELECT_OPTION; }