cwensel

[[ -s "${SDKMAN_DIR}/bin/sdkman-init.sh" ]] && source "${SDKMAN_DIR}/bin/sdkman-init.sh"
export JAVA_8_HOME=$(sdk home java 8.0.362-zulu)
export JAVA_11_HOME=$(sdk home java 11.0.21-zulu)
export JAVA_17_HOME=$(sdk home java 17.0.9-graalce)
export JAVA_21_HOME=$(sdk home java 21.0.1-graalce)
export JAVA_HOME=$JAVA_8_HOME

cwensel

import cascading.flow.Flow;
import cascading.flow.FlowDef;
import cascading.flow.hadoop.HadoopFlowConnector;
import cascading.operation.regex.RegexParser;
import cascading.operation.text.DateFormatter;
import cascading.pipe.Each;
import cascading.pipe.Pipe;
import cascading.scheme.hadoop.TextDelimited;
import cascading.scheme.hadoop.TextLine;
import cascading.tap.SinkMode;

cwensel

import heretical.parser.temporal.DurationParser;
import org.eclipse.microprofile.config.spi.Converter;

import java.time.Duration;

/**
 * Uses <a href="https://github.com/Heretical/mini-parsers">Mini-Parsers</a> to parse a duration string
 * in a config file.
 */
public class DurationConverter implements Converter<Duration> {

cwensel

{
  "app": "${PROJECT_HOME}/gradlew -q run ${GRADLE_OFFLINE_OPTION}",
  "output": "build/cdk.out"
}

cwensel

{
  "app": "${PROJECT_HOME}/gradlew -q run ${GRADLE_OFFLINE_OPTION}",
  "output": "build/cdk.out"
}

cwensel

#!/usr/bin/env sh

APP_NAME="app"

USER_OPT=$(id -u $(logname)):$(id -g $(logname))

if [ -n "${ENTRY_BASH}" ]; then
  ENTRY_OPT="--entrypoint /bin/bash"
fi

cwensel

/*{
    "type": "action",
	"description": "Export images from current document.",
	"label": "Export Canvases",
	"paletteLabel": "Export Canvases"
}*/

var _ = function () {

    var action = new PlugIn.Action(function (selection) {

cwensel

public class S3LogsViaKafka
  {
  public static final String DD_MMM_YYYY = "dd-MMM-yyyy";
  public static final TimeZone UTC = TimeZone.getTimeZone( "UTC" );
  public static final DateType DMY = new DateType( DD_MMM_YYYY, UTC );
  public static final Fields KEY = new Fields( "date", DMY );
  public static final Fields LINE = new Fields( "line", String.class );
  public static final Fields KEY_LINE = KEY.append( LINE );

  public static void main( String[] args )

cwensel

    long count = TupleEntryStream.entryStream( tap, flowProcess ).count();

    assertEquals( 20, count );

    int sum = TupleEntryStream.entryStream( tap, flowProcess )
      .mapToInt( TupleEntryStream.fieldToInt( Fields.FIRST ) )
      .sum();

    assertEquals( 210, sum );

cwensel

import java.io.IOException;
import java.lang.reflect.Type;
import java.util.List;
import java.util.Map;

import cascading.CascadingException;
import cascading.tuple.coerce.Coercions;
import cascading.tuple.type.CoercibleType;
import cascading.util.Util;
import com.fasterxml.jackson.core.JsonProcessingException;