wezhang

Mockito.doReturn("fake hi", null.asInstanceOf[Array[Object]]: _* )

when(t.get()).thenReturn("a", Array[Object](): _*)


v.overloadedMethod(arg0, null.asInstanceOf[Array[Object]]: _*)

wezhang

    val hadoopConf = spark.sparkContext.hadoopConfiguration
    hadoopConf.addResource(new Path("D:\\src\\intellij\\conf\\core-site.xml"))

    val path = new Path("sample.csv")
    val fs = path.getFileSystem(hadoopConf)
    println(fs.open(path).available())

    fs.close()

wezhang

          val dagScheduler = classOf[SparkContext].getDeclaredMethod("dagScheduler").invoke(sc)

          val stageIdToStage = classOf[DAGScheduler].getDeclaredField("stageIdToStage").get(dagScheduler).asInstanceOf[HashMap[Int, Stage]]

          val stage = stageIdToStage(stageInfo.stageId)

wezhang

    DateTimeFormatter timeFormatter = DateTimeFormatter.ISO_DATE_TIME;
    TemporalAccessor accessor = timeFormatter.parse("2015-10-27T16:22:27.605-07:00");

    Date date = Date.from(Instant.from(accessor));
    System.out.println(date);

wezhang

boolean tryParseInt(String value) {  
     try {  
         Integer.parseInt(value);  
         return true;  
      } catch (NumberFormatException e) {  
         return false;  
      }  
}

wezhang

        Task.Backgroundable checkSshCertBackgroundTask = new Task.Backgroundable(
                submitModel.getProject(), "Verify Authentication...", false) {
            @Override
            public void run(@NotNull ProgressIndicator indicator) {
                try {
                    sleep(20 * 1000);
                } catch (InterruptedException e) {
                    e.printStackTrace();
                }

wezhang

Optional.of(new Outer())
    .map(Outer::getNested)
    .map(Nested::getInner)
    .map(Inner::getFoo)
    .ifPresent(System.out::println);

wezhang

import java.util.concurrent.Phaser;

    // Main thread

    // Reset the debug process Phaser
    debugProcessPhaser = new Phaser(1);

    new Thread(() -> {
        // new debug process start
        debugProcessPhaser.register();

wezhang

/**
 * Retry observable subscription if timeout.
 *
 * For every retry it will wait delay + delayAmount so we wait more and more every retry.
 *
 * @param maxRetries number of retries
 * @param delay milliseconds of wait between each try
 * @param delayAmount  delay + delayAmount
 */
class RetryAfterTimeoutWithDelay(val maxRetries: Int, var delay: Long, val delayAmount: Long = 100)

wezhang

public enum UserStatus {
    PENDING,
    ACTIVE,
    INACTIVE,
    DELETED;
}

public enum WhoisRIR {
    ARIN("whois.arin.net"),
    RIPE("whois.ripe.net"),