Skip to content

Instantly share code, notes, and snippets.

View eutkin's full-sized avatar

Eugene Utkin eutkin

  • -
  • Russia, Moscow
View GitHub Profile
package root
import org.apache.ignite.Ignition
import org.apache.ignite.cache.affinity.AffinityKeyMapped
import org.apache.ignite.cache.query.IndexQuery
import org.apache.ignite.cache.query.IndexQueryCriteriaBuilder.lt
import org.apache.ignite.cache.query.annotations.QuerySqlField
import org.apache.ignite.configuration.CacheConfiguration
import org.apache.ignite.configuration.IgniteConfiguration
import java.util.UUID
// See https://aka.ms/new-console-template for more information
/*
1 2 3
1 o | x | o
---+---+---
2 o | x | o
---+---+---
3 x | o | x
package com
import org.apache.ignite.Ignition
import org.apache.ignite.internal.IgniteEx
import org.apache.ignite.internal.processors.cache.binary.CacheObjectBinaryProcessorImpl
import org.msgpack.core.MessagePack
import java.time.LocalDate
import java.time.LocalDateTime
import java.time.LocalTime
import java.time.ZoneOffset
package com.github.eutkin;
@SuppressWarnings("UNCHECKED_CAST")
public class ArrayList<T> implements List<T> {
private Object[] array;
private int size;
package com.github.yseagull;
import java.util.Arrays;
import java.util.Random;
public class App {
public static void main(String[] args) {
// Инициализируем массив из 10 элементов (ячеек). Каждая ячейка хранит одно число.
int[] array = new int[10];
import zone.bi.iso8583.client.MessageType
import zone.bi.iso8583.client.Unpacker
import zone.bi.iso8583.serialize.serialize
import java.net.InetSocketAddress
import java.nio.ByteBuffer
import java.nio.ByteOrder
import java.nio.channels.FileChannel
import java.nio.channels.SocketChannel
import java.nio.file.Files
import java.nio.file.Path
package com.github.eutkin
import reactor.core.publisher.Flux
import reactor.core.publisher.Mono
import java.io.InputStream
import java.math.BigDecimal
import java.math.MathContext
import java.time.Duration
import java.util.concurrent.ThreadLocalRandom
import java.util.concurrent.atomic.AtomicBoolean
package com.github.eutkin
import reactor.core.publisher.Flux
import reactor.core.publisher.Mono
import java.io.InputStream
import java.math.BigDecimal
import java.math.MathContext
import java.time.Duration
import java.util.concurrent.ThreadLocalRandom
import java.util.concurrent.atomic.AtomicBoolean
fun main() {
// val --> неизменяемая ссылка на объект (в нашем случае объект типа Function
// transformer --> имя переменной aka имя ссылки на объект
// : --> разделяет имя переменной и ее тип
// (Int) -> String --> тип переменной, функция, принимающая (в скобочках) целое число (тип Int) и возвращающая (после стрелочки) строковый тип (String)
// = --> оператор присвоения значения переменной
// { .. } --> содержат функцию целиком
// element : Int --> аргумент функции с именем element и типом Int
import java.time.Duration
import javax.cache.processor.EntryProcessor
EntryProcessor<String, List<Map<String, Any?>>, List<Any?>> { entry, args ->
data class ExtParameter(
val function: String,
val historyFilter: (Map<String, Any?>) -> Boolean,