@SuppressWarnings("rawtypes") @Override protected Class<? extends CombineFileInputFormat> getCombineFileInputFormatClass() { //TODO return null;//CombineJsonInputFormat.class; }
@SuppressWarnings("rawtypes") protected Class<? extends CombineFileInputFormat> getCombineFileInputFormatClass() { return null; }
/** * Java wrapper for * {@link CombineFileInputFormat#addInputPath(org.apache.hadoop.mapreduce.Job, org.apache.hadoop.fs.Path)}. * * @param ctx the JavaScript context * @param thisObj the 'this' object * @param args the function arguments * @param func the function being called */ @JSStaticFunction public static void addInputPath(final Context ctx, final Scriptable thisObj, final Object[] args, final Function func) { FileInputFormatHelper.addInputPath(CombineFileInputFormat.class, ctx, thisObj, args); }
/** * Java wrapper for * {@link CombineFileInputFormat#addInputPaths(org.apache.hadoop.mapreduce.Job, String)}. * * @param ctx the JavaScript context * @param thisObj the 'this' object * @param args the function arguments * @param func the function being called */ @JSStaticFunction public static void addInputPaths(final Context ctx, final Scriptable thisObj, final Object[] args, final Function func) { FileInputFormatHelper.addInputPaths(CombineFileInputFormat.class, ctx, thisObj, args); }
/** * Java wrapper for {@link CombineFileInputFormat#getInputPathFilter(org.apache.hadoop.mapreduce.JobContext)}. * * @param ctx the JavaScript context * @param thisObj the 'this' object * @param args the function arguments * @param func the function being called * * @return class name for the input path filter or undefined */ @JSStaticFunction public static Object getInputPathFilter(final Context ctx, final Scriptable thisObj, final Object[] args, final Function func) { return FileInputFormatHelper.getInputPathFilter(CombineFileInputFormat.class, ctx, thisObj, args); }
/** * Java wrapper for {@link CombineFileInputFormat#getInputPaths(org.apache.hadoop.mapreduce.JobContext)}. * * @param ctx the JavaScript context * @param thisObj the 'this' object * @param args the function arguments * @param func the function being called * * @return array of input paths */ @JSStaticFunction public static Object getInputPaths(final Context ctx, final Scriptable thisObj, final Object[] args, final Function func) { return FileInputFormatHelper.getInputPaths(CombineFileInputFormat.class, ctx, thisObj, args); }
/** * Java wrapper for {@link CombineFileInputFormat#getMaxSplitSize(org.apache.hadoop.mapreduce.JobContext)}. * * @param ctx the JavaScript context * @param thisObj the 'this' object * @param args the function arguments * @param func the function being called * * @return the max split size */ @JSStaticFunction public static Object getMaxSplitSize(final Context ctx, final Scriptable thisObj, final Object[] args, final Function func) { return FileInputFormatHelper.getMaxSplitSize(CombineFileInputFormat.class, ctx, thisObj, args); }
/** * Java wrapper for {@link CombineFileInputFormat#getMinSplitSize(org.apache.hadoop.mapreduce.JobContext)}. * * @param ctx the JavaScript context * @param thisObj the 'this' object * @param args the function arguments * @param func the function being called * * @return the max split size */ @JSStaticFunction public static Object getMinSplitSize(final Context ctx, final Scriptable thisObj, final Object[] args, final Function func) { return FileInputFormatHelper.getMinSplitSize(CombineFileInputFormat.class, ctx, thisObj, args); }
/** * Wraps {@link CombineFileInputFormat#setInputPathFilter(org.apache.hadoop.mapreduce.Job, Class)}. * * @param ctx the JavaScript context (unused) * @param thisObj the 'this' object of the caller * @param args the arguments for the call * @param func the function called (unused) */ @JSStaticFunction public static void setInputPathFilter(final Context ctx, final Scriptable thisObj, final Object[] args, final Function func) { FileInputFormatHelper.setInputPathFilter(CombineFileInputFormat.class, ctx, thisObj, args); }
/** * Java wrapper for * {@link CombineFileInputFormat#setInputPaths(org.apache.hadoop.mapreduce.Job, org.apache.hadoop.fs.Path...)} and * {@link CombineFileInputFormat#setInputPaths(org.apache.hadoop.mapreduce.Job, String)}. * * @param ctx the JavaScript context * @param thisObj the 'this' object * @param args the function arguments * @param func the function being called */ @JSStaticFunction public static void setInputPaths(final Context ctx, final Scriptable thisObj, final Object[] args, final Function func) { FileInputFormatHelper.setInputPaths(CombineFileInputFormat.class, ctx, thisObj, args); }
/** * Java wrapper for {@link CombineFileInputFormat#setMaxInputSplitSize(org.apache.hadoop.mapreduce.Job, long)}. * * @param ctx the JavaScript context * @param thisObj the 'this' object * @param args the function arguments * @param func the function being called */ @JSStaticFunction public static void setMaxInputSplitSize(final Context ctx, final Scriptable thisObj, final Object[] args, final Function func) { FileInputFormatHelper.setMaxInputSplitSize(CombineFileInputFormat.class, ctx, thisObj, args); }
/** * Java wrapper for {@link CombineFileInputFormat#setMinInputSplitSize(org.apache.hadoop.mapreduce.Job, long)}. * * @param ctx the JavaScript context * @param thisObj the 'this' object * @param args the function arguments * @param func the function being called */ @JSStaticFunction public static void setMinInputSplitSize(final Context ctx, final Scriptable thisObj, final Object[] args, final Function func) { FileInputFormatHelper.setMinInputSplitSize(CombineFileInputFormat.class, ctx, thisObj, args); }