Advertisement
Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- public static int countLines(String filename) throws IOException {
- InputStream is = new BufferedInputStream(new FileInputStream(filename));
- try {
- byte[] c = new byte[1024];
- int count = 0;
- int readChars = 0;
- boolean empty = true;
- while ((readChars = is.read(c)) != -1) {
- empty = false;
- for (int i = 0; i < readChars; ++i) {
- if (c[i] == 'n') {
- ++count;
- }
- }
- }
- return (count == 0 && !empty) ? 1 : count;
- } finally {
- is.close();
- }
- }
- @Transformer
- public JobLaunchRequest toRequest(Message<File> message) throws IOException{
- JobParametersBuilder jobParametersBuilder = new JobParametersBuilder();
- jobParametersBuilder.addString("commit.interval", Integer.toString(countLines(message.getPayload().getAbsolutePath())));
- return new JobLaunchRequest(job, jobParametersBuilder.toJobParameters());
- }
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement